I just discovered 'resolve_xcom_backend' and looked at the source code and it appears to explicitly load the XCom class from the configuration. https://airflow.apache.org/docs/apache-airflow/stable/_api/airflow/models/xcom/index.html#airflow.models.xcom.resolve_xcom_backend Should this be called in the DAG? Is it necessary to call this function? If someone can give me points then i will provide a pull request to augment the documentation as there doesn't appear to be any. Thanks lewismc
On 2022/01/05 22:41:22 lewis john mcgibbney wrote: > Hi users@, > > We wish to use a custom XCom something similar to what is presented in the > following Astronomer guide on the topic. > https://www.astronomer.io/guides/custom-xcom-backends > > My question is, when running Airflow on K8s, what is the best mechanism to > verify that a custom XCom implementation, defined in values.yaml, is > actually being loaded? > Is there some DEBUG/TRACE logging statement I can look out for or something > similar? > > Thank you > lewismc > > -- > http://home.apache.org/~lewismc/ > http://people.apache.org/keys/committer/lewismc >
