stijndehaes commented on issue #16625:
URL: https://github.com/apache/airflow/issues/16625#issuecomment-895776139
We noticed a similar issue with Airflow 2.1.2. Job went from queued to
failed without retry, looking at the code I am not sure how to fix it. It is
clear that in `scheduler_job.py` on line 1238 we see the relevant logs. Maybe
there should be logic here to check if the task needs to be retried and change
the state to retried if needed?
The relevant logs (the dag and task name are erased because they might
contain sensitive information):
```
-----------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------
| @timestamp |
log
|
|-------------------------|-------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------|
| 2021-08-06 17:27:30.210 | [2021-08-06 17:27:30,209]
{scheduler_job.py:1254} ERROR - Executor reports task instance <TaskInstance:
xxxx 1990-06-10 00:00:00+00:00 [queued]> finished (failed) although the task
says its queued. (Info: None) Was the task killed externally?
|
| 2021-08-06 17:27:30.205 | [2021-08-06 17:27:30,204]
{scheduler_job.py:1218} INFO - Executor reports execution of xxxx
execution_date=1990-06-10 00:00:00+00:00 exited with status failed for
try_number 5
|
| 2021-08-06 17:27:30.204 | [2021-08-06 17:27:30,204]
{kubernetes_executor.py:546} INFO - Changing state of
(TaskInstanceKey(dag_id='xxxx', task_id='xxxx',
execution_date=datetime.datetime(1990, 6, 10, 0, 0, tzinfo=tzlocal()),
try_number=5), 'failed', 'xxxx, 'dev', '97113730') to failed
|
| 2021-08-06 17:27:30.203 | [2021-08-06 17:27:30,202]
{kubernetes_executor.py:368} INFO - Attempting to finish pod; pod_id: xxxx;
state: failed; annotations: {'dag_id': 'xxxx', 'task_id': 'xxxx',
'execution_date': '1990-06-10T00:00:00+00:00', 'try_number': '5'}
|
| 2021-08-06 17:22:23.371 | [2021-08-06 17:22:23,371]
{scheduler_job.py:1245} INFO - Setting external_id for <TaskInstance: xxxx
1990-06-10 00:00:00+00:00 [queued]> to 1606
|
| 2021-08-06 17:22:23.367 | [2021-08-06 17:22:23,367]
{scheduler_job.py:1218} INFO - Executor reports execution of xxxx
execution_date=1990-06-10 00:00:00+00:00 exited with status queued for
try_number 5
|
2021-08-06 17:27:30.205 | [2021-08-06 17:27:30,204] {scheduler_job.py:1218}
INFO - Executor reports execution of xxxxr execution_date=1990-06-10
00:00:00+00:00 exited with status failed for try_number 5
```
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
