samraj2k commented on code in PR #67592:
URL: https://github.com/apache/airflow/pull/67592#discussion_r4148520112
##########
airflow-core/src/airflow/api_fastapi/execution_api/routes/task_instances.py:
##########
@@ -244,6 +251,12 @@ def ti_run(
extra=json.dumps({"host_name": ti_run_payload.hostname}) if
ti_run_payload.hostname else None,
)
)
+ # One sample per queue wait, not per try: the scheduler refreshes
queued_dttm on every
+ # queueing, so a retry and a resume from deferral each waited for a
slot of their own.
+ # task.scheduled_duration counts per try instead, so the two disagree
on retries by design.
+ # queued_dttm is None only in rare races and test setups.
Review Comment:
nit: I dont think there are any particular race due to which queued_dttm is
none, though we can keep this since during dag.test() queued_dttm is null and
also its a nullable column in db
--
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]
