2

我在 Docker 容器中使用 Airflow。我使用多个 Jupyter 笔记本运行 DAG。每次 60 分钟后我都会出现以下错误：

[2021-08-22 09:15:15,650] {local_task_job.py:198} WARNING - State of this instance has been externally set to skipped. Terminating instance.
[2021-08-22 09:15:15,654] {process_utils.py:100} INFO - Sending Signals.SIGTERM to GPID 277
[2021-08-22 09:15:15,655] {taskinstance.py:1284} ERROR - Received SIGTERM. Terminating subprocesses.
[2021-08-22 09:15:18,284] {taskinstance.py:1501} ERROR - Task failed with exception

我试图调整配置文件，但找不到删除 1 小时超时的好选择。任何帮助，将不胜感激。

4

1 回答 1

3

默认为无超时。当您的 DAG 定义dagrun_timeout=timedelta(minutes=60)且执行时间超过 60 分钟时，活动任务将停止并记录消息“此实例的状态已在外部设置为已跳过”。

于 2021-08-22T17:10:11.187 回答