如何解决on_failure_callback 在气流 DAG() 中不起作用
我想为 dag 失败和成功调用两个不同的函数。为此,我想在 DAG() 函数中使用 on_failure_callback 和 on_success_callback。
根据我的要求,这个回调应该在 dag 级别而不是任务级别。这就是为什么我在声明 dag 变量的同时编写这个回调 insiled DAG() 函数。
但是这个回调函数没有被调用。如果我在任务级别调用相同的功能,那么工作正常。
这是我的代码:
def success():
print("successful")
dag = DAG(dag_id='callback_test',schedule_interval=None,default_args=default_args,on_success_callback=success)
def fun1(**kwargs):
print("function called")
task1 = Pythonoperator(
task_id='task1',provide_context=True,python_callable=fun1,dag=dag
)
task1
解决方法
然而,我认为它也应该在 DAG 级别工作,根据这个: https://airflow.apache.org/docs/apache-airflow/1.10.10/_api/airflow/models/dag/index.html?highlight=on_failure_callback
对吗?
不过,我无法让它工作:(
版权声明:本文内容由互联网用户自发贡献,该文观点与技术仅代表作者本人。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容, 请发送邮件至 dio@foxmail.com 举报,一经查实,本站将立刻删除。