python - 访问运算符(operator)外部的 Airflow 运算符(operator)值

Question

在运算符之外，我需要使用 xcom 调用 SubdagOperator 并向其传递运算符的返回值。我见过很多解决方案( Airflow - How to pass xcom variable into Python function 、 How to retrieve a value from Airflow XCom pushed via SSHExecuteOperator 等)。

他们基本上都说 'variable_name': "{{ ti.xcom_pull(task_ids='some_task_id') }}"

但是我的 Jinja 模板不断呈现为字符串，并且不返回实际变量。有什么想法吗？

这是我当前在主 dag 中的代码:

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
)

Answer 1

引用太多？试试这个

"{{ ti.xcom_pull(task_ids='get_num_accounts', dag_id='" + PARENT_DAG_NAME + "') }}"