如何解决气流不呈现时间增量参数
我正在尝试将 timedelta(hours=2)
作为参数传递给作为 DAG
之一的 default_args
。我从配置文件中读取了一些参数,如下所示:config = {'name': 'task1','freq': 'Daily','timeout': 'timedelta(hours=2)' }
然后我尝试将其传递给 default_args
,但从 dag 细节来看,气流无法识别它。我在这里做错了什么?非常感谢您的帮助。
timeout = config["timeout"]
default_args ={
"retries" =0,"execution_timeout" = timeout
}
解决方法
从配置文件中获取 DAG 参数不是一个好习惯,因为您可能会在 Airflow 中出现一些奇怪的行为。对于你的问题,你有一个函数的字符串,你可以使用 eval()
来完成你所需要的。
试试这个(我重构了你的代码,因为它不能正常工作):
timeout = config["timeout"]
default_args = {
"retries": 0,"execution_timeout": eval(timeout),}
版权声明:本文内容由互联网用户自发贡献,该文观点与技术仅代表作者本人。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容, 请发送邮件至 dio@foxmail.com 举报,一经查实,本站将立刻删除。