Python中文
首页
教程
问答
标签
搜索
登录
注册
气流Python操作符,带a.return类型
回答此问题可获得
20
贡献值,回答如果被采纳可获得
50
分。
<p>我的DAG中有一个python操作符。python可调用函数返回bool值。但是,当我运行DAG时,我得到了下面的错误。在</p> <blockquote> <p>TypeError: 'bool' object is not callable</p> </blockquote> <p>我修改了这个函数,使它什么也不返回,但是我仍然得到下面的错误</p> <blockquote> <p>ERROR - 'NoneType' object is not callable</p> </blockquote> <p>下面是我的狗狗</p> <pre><code>def check_poke(threshold,sleep_interval): flag=snowflake_poke(1000,10).poke() #print(flag) return flag dependency = PythonOperator( task_id='poke_check', #python_callable=check_poke(129600,600), provide_context=True, python_callable=check_poke(129600,600), dag=dag) end = BatchEndOperator( queue=QUEUE, dag=dag) start.set_downstream(dependency) dependency.set_downstream(end) </code></pre> <p>我不知道我错过了什么。有人能帮我解决这个问题吗…对气流来说是个新手。在</p> <p>我在dag中编辑了python操作符,如下所示</p> ^{pr2}$ <p>但是现在,我得到了一个不同的错误。在</p> <pre><code>Traceback (most recent call last): File "/usr/local/lib/python2.7/dist-packages/airflow/models.py", line 1245, in run result = task_copy.execute(context=context) File "/usr/local/lib/python2.7/dist-packages/airflow/operators/python_operator.py", line 66, in execute return_value = self.python_callable(*self.op_args, **self.op_kwargs) TypeError: () takes no arguments (25 given) [2019-02-15 05:30:25,375] {models.py:1298} INFO - Marking task as UP_FOR_RETRY [2019-02-15 05:30:25,393] {models.py:1327} ERROR - () takes no arguments (25 given) </code></pre>
0 条评论
分类:
Python问答
请先
登录
后评论
默认排序
时间排序
1 个回答
匿名
1天前
擅长:python、mysql、java
<p>参数名提供了它。您正在传递调用的结果,而不是可调用的。在</p> <pre><code>python_callable=check_poke(129600,600) </code></pre> <p>第二个错误说明调用可调用的参数有25个。所以<code>lambda:</code>不起作用。下面的方法可能有用,但忽略25个论点确实值得怀疑。在</p> ^{pr2}$
请先
登录
后评论
针对此问题:
更多的回答
关注
89
关注
收藏
1
收藏,
216
浏览
网友 提问于 2天前
相关Python问题
为什么我的神经网络模型的准确性不能在这个训练集上得到提高?
4 回答
为什么我的神经网络模型的权重变化不大?
2 回答
为什么我的神经网络的成本不断增加?
10 回答
为什么我的神经网络的输入pickle文件是19GB?
1 回答
为什么我的神经网络给属性错误?“非类型”对象没有属性“形状”
8 回答
为什么我的神经网络训练这么慢?
9 回答
为什么我的神经网络输出错误?
1 回答
为什么我的神经网络预测适用于MNIST手绘图像时是正确的,而适用于我自己的手绘图像时是不正确的?
6 回答
为什么我的神经网络验证精度比我的训练精度高,而且它们都是常数?
3 回答
为什么我的私人用户间聊天会显示在其他用户的聊天档案中?
5 回答
为什么我的积分的绝对误差估计值大于积分(使用scipy.integrate.nqad)?
10 回答
为什么我的积层回归器得分比它的组件差?
9 回答
为什么我的移动方法不起作用?
3 回答
为什么我的稀疏张量不能转换成张量
5 回答
为什么我的稀疏张量不能转换成张量?
8 回答
为什么我的程序“停止”了?
4 回答
为什么我的程序一直试图占用所有可用的CPU
9 回答
为什么我的程序不使用指定的代理
8 回答
为什么我的程序不工作(python帮助中的反向函数)?
8 回答
为什么我的程序不工作时,我使用多处理模块
1 回答