Python中文
首页
教程
问答
标签
搜索
登录
注册
访问op之外的气流操纵器值
回答此问题可获得
20
贡献值,回答如果被采纳可获得
50
分。
<p>在操作符之外,我需要调用SubdagOperator,并使用xcom将操作符的返回值传递给它。我见过很多解决方案(<a href="https://stackoverflow.com/questions/46059161/airflow-how-to-pass-xcom-variable-into-python-function">Airflow - How to pass xcom variable into Python function</a>,<a href="https://stackoverflow.com/questions/42974051/how-to-retrieve-a-value-from-airflow-xcom-pushed-via-sshexecuteoperator">How to retrieve a value from Airflow XCom pushed via SSHExecuteOperator</a>,等等)。在</p> <p>它们基本上都说“变量名”:“{提拉(task_ids='some\u task\u id')}“</p> <p>但是我的Jinja模板一直被呈现为一个字符串,并且没有返回实际的变量。有什么想法为什么?在</p> <p>以下是我在主dag中的当前代码:</p> <pre><code>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 ) </code></pre>
0 条评论
分类:
Python问答
请先
登录
后评论
默认排序
时间排序
1 个回答
匿名
1天前
擅长:python、mysql、java
<p>报价太多?试试这个</p> <pre><code>"{{ ti.xcom_pull(task_ids='get_num_accounts', dag_id='" + PARENT_DAG_NAME + "') }}" </code></pre>
请先
登录
后评论
针对此问题:
更多的回答
关注
89
关注
收藏
1
收藏,
216
浏览
网友 提问于 2天前
相关Python问题
无法使用Django/mongoengine连接到MongoDB(身份验证失败)
1 回答
无法使用Django\u mssql\u后端迁移到外部hos
1 回答
无法使用Django&Python3.4连接到MySql
9 回答
无法使用Django+nginx上载媒体文件
6 回答
无法使用Django1.6导入名称模式
8 回答
无法使用Django1.7和mongodb登录管理站点
10 回答
无法使用Djangoadmin创建项目,进程使用了错误的路径,因为我事先安装了错误的Python
8 回答
无法使用Djangockedi验证CBV中的字段
1 回答
无法使用Djangocketditor上载图像(错误400)
5 回答
无法使用Djangocron进行函数调用
1 回答
无法使用Djangofiler djang上载文件
2 回答
无法使用Djangokronos
6 回答
无法使用Djangomssql provid
10 回答
无法使用Djangomssql连接到带有Django 1.11的MS SQL Server 2016
10 回答
无法使用Djangomssq迁移Django数据库
3 回答
无法使用Djangonox创建用户
3 回答
无法使用Djangopyodb从Django查询SQL Server
2 回答
无法使用Djangopython3ldap连接到ldap
6 回答
无法使用Djangoredis连接到redis
9 回答
无法使用Django中的FK创建新表
1 回答