jedcunningham commented on code in PR #40141:
URL: https://github.com/apache/airflow/pull/40141#discussion_r1633835287
##########
airflow/jobs/backfill_job_runner.py:
##########
@@ -313,9 +313,14 @@ def _manage_executor_state(
and ti.state in self.STATES_COUNT_AS_RUNNING
):
msg = (
- f"Executor reports task instance {ti} finished ({state})
although the task says its "
- f"{ti.state}. Was the task killed externally? Info: {info}"
+ f"The executor reported that the task instance {ti}
finished with state {state}, "
+ f"but the task instance's state attribute is {ti.state}. "
+ "This indicates that the task was marked failed by
something other than the scheduler. "
Review Comment:
It might not be marked failed though? Should you be using `ti.state` here?
--
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]
