0

我有一个任务Airflow 2.1.2以成功状态完成,但在该日志显示一个 sigterm 之后:

[2021-12-07 06:11:45,031] {python.py:151} INFO - Done. Returned value was: None
[2021-12-07 06:11:45,224] {taskinstance.py:1204} INFO - Marking task as SUCCESS. dag_id=DAG_ID, task_id=TASK_ID, execution_date=20211207T050000, start_date=20211207T061119, end_date=20211207T061145
[2021-12-07 06:11:45,308] {local_task_job.py:197} WARNING - State of this instance has been externally set to success. Terminating instance.
[2021-12-07 06:11:45,309] {taskinstance.py:1265} INFO - 0 downstream tasks scheduled from follow-on schedule check
[2021-12-07 06:11:45,310] {process_utils.py:100} INFO - Sending Signals.SIGTERM to GPID 6666
[2021-12-07 06:11:45,310] {taskinstance.py:1284} ERROR - Received SIGTERM. Terminating subprocesses.
[2021-12-07 06:11:45,362] {process_utils.py:66} INFO - Process psutil.Process(pid=6666, status='terminated', exitcode=1, started='06:11:19') (6666) terminated with exit code 1

如您所见,第一行返回Done,并且此日志的前几行显示所有脚本都运行良好并且数据已插入Datawarehouse.

在第 8 行中,它显示SIGTERM由于一些外部触发器将其标记为成功,但我确信没有人使用API,或者CLI将其标记为成功也没有UI. 知道如何避免它,为什么会发生这种情况?

我不知道是否可能增加AIRFLOW_CORE_KILLED_TASK_CLEANUP_TIME可以解决它,但我想了解它。

4

0 回答 0