Python中文
首页
教程
问答
标签
搜索
登录
注册
运行时配置为PythonOp
回答此问题可获得
20
贡献值,回答如果被采纳可获得
50
分。
<p>我找不到任何关于如何使用通过“-c”传递的JSON变量的工作文档,例如回填作业。在</p> <p>我一直在打印我的python任务**kwargs以找出答案,但我仍然无法确定它。提供_context=True</p> <p>谁能给我指出正确的方向吗?在</p> <p>所以,我想做的是:</p> <pre><code>airflow backfill mydag -c '{"override":"yes"}' -s 2018-12-01 -e 2018-12-12 </code></pre> <p>我有一只Python:</p> ^{pr2}$ <p>在run_task中,我想访问override变量:</p> <pre><code>def run_task(*args, **kwargs): dag_run = kwargs.get('dag_run') logging.info(kwargs['dag_run'].conf.get('override')) </code></pre> <p>但是我找不到访问这个覆盖变量的方法</p> <pre><code>[2018-12-17 10:07:24,649] {models.py:1760} ERROR - 'NoneType' object has no attribute 'get' Traceback (most recent call last): File "/home/daimonie/.local/lib/python3.6/site-packages/airflow/models.py", line 1659, in _run_raw_task result = task_copy.execute(context=context) File "/home/daimonie/.local/lib/python3.6/site-packages/airflow/operators/python_operator.py", line 95, in execute return_value = self.execute_callable() File "/home/daimonie/.local/lib/python3.6/site-packages/airflow/operators/python_operator.py", line 100, in execute_callable return self.python_callable(*self.op_args, **self.op_kwargs) File "/home/daimonie/airflow/dags/dag_scheduled_queries.py", line 65, in run_query logging.info(kwargs['dag_run'].conf.get('override')) </code></pre> <p>编辑:我确实找到了一个配置设置和描述,似乎表明这些参数需要在代码中设置</p> <pre><code># Whether to override params with dag_run.conf. If you pass some key-value pairs through `airflow backfill -c` or # `airflow trigger_dag -c`, the key-value pairs will override the existing ones in params. dag_run_conf_overrides_params=True </code></pre> <p>donot_pickle参数设置为False。在</p>
0 条评论
分类:
Python问答
请先
登录
后评论
默认排序
时间排序
1 个回答
匿名
1天前
擅长:python、mysql、java
<p>你需要做两件事。在</p> <ol> <li>将<code>kwargs['run_dag'].conf.get('override')</code>替换为<code>kwargs['dag_run'].conf.get('override')</code>。在</li> <li>同时更改签名 从<code>def run_task(*args, **kwargs):</code>到{<cd4>}</li> </ol>
请先
登录
后评论
针对此问题:
更多的回答
关注
89
关注
收藏
1
收藏,
216
浏览
网友 提问于 2天前
相关Python问题
我想从用户inpu创建一个类的实例
5 回答
我想从用户导入值,为此
7 回答
我想从用户那里得到一个整数输入,然后让for循环遍历该数字,然后调用一个函数多次
2 回答
我想从用户那里收到一个列表,并在其中执行一些步骤,然后在步骤完成后将其打印回来,但它没有按照我想要的方式工作
10 回答
我想从用户那里获取输入,并将值传递给(average=dict[x]/6),然后在那里获取resu
8 回答
我想从第一个列表中展示第一个词,然后从第二个列表中展示十个词,以此类推- Python
3 回答
我想从第一个空lin开始解析文本文件
4 回答
我想从简历、简历中提取特定部分
1 回答
我想从给定字典(python)的字符串中删除\u00a9、\u201d和类似的字符。
4 回答
我想从给定的网站Lin下载许多文件扩展名相同的Wget或Python文件
8 回答
我想从网上搜集一些关于抵押贷款的数据
3 回答
我想从网站上删除电子邮件地址
9 回答
我想从网站上读取数据该网站包含可下载的文件,然后我想用python脚本把它发送给oracle如何?
6 回答
我想从网站中提取数据,然后将其显示在我的网页上
8 回答
我想从网页上提取统计数据。
7 回答
我想从网页上解析首都城市,并在用户输入国家时在终端上打印它们
7 回答
我想从色彩图中删除前n个颜色,而不丢失原始颜色数
10 回答
我想从课堂上打印字典里的键
5 回答
我想从费用表中获取学生上次支付的费用,其中学生id=id
4 回答
我想从较低的顺序对多重列表进行排序,但我无法在一行中生成结果
10 回答