Невозможно извлечь старое значение xcom с помощью xcom_pull () в Airflow - PullRequest
0 голосов
/ 21 апреля 2020

Я попробовал приведенный ниже код для извлечения старого значения xcom, но он возвращает None, хотя тот же ключ доступен в xcom.

jira_created_list = context['task_instance'].xcom_pull(key="jira_created_list").

Мое требование заключается в том, что в любой день мой DAG будет выполнен, и Pu sh отправит некоторые данные в xcom, а затем, когда будет запущен тот же DAG, он должен извлечь значение xcom, которое было выдвинуто DAG, запущенным вчера, но я не могу достичь этого сценария. Пожалуйста, помогите мне найти решение.

...