气流不呈现 timedelta 参数

Question

我正在尝试将 timedelta(hours=2) 作为参数传递给作为 default_args 之一的 DAG。我从配置文件中读取了一些参数，如下所示：config = {'name': 'task1', 'freq': 'Daily', 'timeout': 'timedelta(hours=2)' }

然后我尝试将它传递给一个default_args，但是从dag 的细节来看，airflow 没有识别它。我在这里做错了什么？非常感谢您的帮助。

timeout = config["timeout"]
default_args ={
     "retries" =0,
     "execution_timeout" = timeout
  }

Answer 1

从配置文件中获取 DAG args 不是一个好的做法，因为您在 Airflow 中可能会有一些奇怪的行为。对于你的问题，你有一个函数的字符串，为了完成你需要的，你可以使用 eval().

试试这个（我重构了你的代码，因为它不能正常工作）：

timeout = config["timeout"]
default_args = {
    "retries": 0,
    "execution_timeout": eval(timeout),
}

气流不呈现 timedelta 参数

Airflow not render timedelta parameter

python

airflow