小编Vad*_*nko的帖子

Apache Airflow 如何将 xcom_pull() 值转换为 DAG?

我有一个自定义运算符,它推送 XCOM 值,如下所示:

...
task_instance = context['task_instance']
task_instance.xcom_push("list_of_files",file_list)
...
Run Code Online (Sandbox Code Playgroud)

它工作正常。我有一个 dag 定义文件 (my_dag.py),我在其中使用自己的运算符创建了一个任务,它推送 XCOM 值,然后我想通过使用此 xcom 值在循环中执行 for。怎么拉?

python apache directed-acyclic-graphs airflow

6
推荐指数
1
解决办法
6086
查看次数

标签 统计

airflow ×1

apache ×1

directed-acyclic-graphs ×1

python ×1