У нас есть DAG, назовите его A, который запускается.Когда этот DAG закончится, мы хотели бы иметь еще один DAG, называемый B, сработавший.Мы получили это для работы с ExternalTaskSensor, но есть ли способ для B прочитать какие-либо значения xcom из A?
Я пытался использовать
{{ task_instance.xcom_pull(dag_id='a dag_id', task_ids='a task_id', key='a key') }}
, но этовозвращает None, поэтому я предполагаю, что он предназначен для использования только между задачами в одном DAG.