小编Pri*_*vas的帖子

我在气流 DAG 中运行 5 个 PythonOperator 任务，其中之一正在执行 ETL 作业，该作业需要很长时间，因此我的所有资源都被阻塞。有没有办法可以设置每个任务的最大执行时间，之后任务要么失败，要么通过消息标记为成功（以便 DAG 不会失败）？