kaxil commented on code in PR #49477:
URL: https://github.com/apache/airflow/pull/49477#discussion_r2052626124
##########
airflow-core/src/airflow/api_fastapi/execution_api/routes/task_instances.py:
##########
@@ -141,7 +141,11 @@ def ti_run(
# If we are already running, but this is a duplicate request from the same
client return the same OK
# -- it's possible there was a network glitch and they never got the
response
- if previous_state == TaskInstanceState.RUNNING and (ti["hostname"],
ti["unixname"], ti["pid"]) == (
+ if previous_state == TaskInstanceState.RUNNING and (
+ ti._mapping["hostname"],
+ ti._mapping["unixname"],
+ ti._mapping["pid"],
Review Comment:
Is there a way to avoid using internal `_mapping`?
--
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]
