Airflow not render timedelta参数

Question

我尝试将timedelta(hours=2)作为参数传递给DAG作为default_args之一。我从配置文件中读取了一些参数，如下所示：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参数并不是一种好的做法，因为在Airflow中可能会出现一些奇怪的行为。对于您的问题，您有一个函数的字符串，您可以使用eval()来完成所需的操作。

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

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