Вне оператора мне нужно вызвать SubdagOperator и передать ему возвращаемое значение оператора, используя xcom. Я видел множество решений (Airflow — Как пройти xcom в функцию Python, Как для получения значения из Airflow XCom, отправленного через SSHExecuteOperator, и т. д.).
Все они обычно говорят «имя_переменной»: «{{ti.xcom_pull (task_ids = ‘some_task_id’)}}»
Но мой шаблон Jinja продолжает отображаться как строка и не возвращает фактическую переменную. Есть идеи, почему?
Вот мой текущий код в главном даге:
PARENT_DAG_NAME = ‘my_main_dag’ CHILD_DAG_NAME = ‘run_featurization_dag’ run_featurization_task = SubDagOperator( task_id=CHILD_DAG_NAME, subdag=run_featurization_sub_dag(PARENT_DAG_NAME, CHILD_DAG_NAME, default_args, cur_date, «‘{{ ti.xcom_pull(task_ids=’get_num_accounts’, dag_id='» + PARENT_DAG_NAME + «‘) }}'» ), default_args=default_args, dag=main_dag )
Источник: