utkarsharma2 commented on code in PR #43063:
URL: https://github.com/apache/airflow/pull/43063#discussion_r1876008546
##########
airflow/jobs/backfill_job_runner.py:
##########
@@ -309,6 +309,16 @@ def _manage_executor_state(
self.log.debug("Executor state: %s task %s", state, ti)
+ if (
+ state in (TaskInstanceState.FAILED, TaskInstanceState.SUCCESS)
+ and ti.state in self.STATES_COUNT_AS_RUNNING
+ ):
+ self.log.debug(
+ "In-memory TaskInstance state %s does not agree with
executor state %s. Attempting to resolve by refreshing in-memory task instance
from DB.",
+ ti, state
+ )
Review Comment:
```suggestion
self.log.debug(
"In-memory TaskInstance state %s does not agree with
executor state %s. Attempting to resolve by refreshing in-memory task instance
from DB.",
ti,
state,
)
```
--
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]
