huozhanfeng edited a comment on pull request #17305:
URL: https://github.com/apache/airflow/pull/17305#issuecomment-919938155
> > Maybe there are other cases to cause the issue... You can print the
content of `ti.key` and `ti_status.running` in function `_update_counters` to
get the details.
>
> Hi, so I was not clear. Fix from PR resolves issue with `KeyError:
TaskInstanceKey ...`,
> but task is looped until timeout.
> Attempt counter is not updated, task logs contains sequence of info like
below
>
> ```
>
>
--------------------------------------------------------------------------------
> [2021-09-13 11:16:50,930] {taskinstance.py:1088} INFO - Starting attempt 1
of 4
> [2021-09-13 11:16:50,930] {taskinstance.py:1089} INFO -
>
--------------------------------------------------------------------------------
> ...
>
--------------------------------------------------------------------------------
> [2021-09-15 10:33:37,692] {taskinstance.py:1088} INFO - Starting attempt 1
of 4
> [2021-09-15 10:33:37,692] {taskinstance.py:1089} INFO -
>
--------------------------------------------------------------------------------
> ...
> ```
>
> until timeout is reached.
> It is expected that after reaching attempts threshold it will fail.
Is it in a rescheduling state? if so, it's reasonable because the attempt
sequence num only is updated when the task runs into failure. And In
rescheduling state, it only means the upstream is not met and will try again
until upstream is done.
--
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]
