cbuffett commented on issue #34497:
URL: https://github.com/apache/airflow/issues/34497#issuecomment-1853083625
Unfortunately I'm still seeing the infinite rescheduling issue after
upgrading to Airflow 2.7.2. I believe the issue still revolves around the fact
that the following code returns an empty list, even on subsequent rescheduled
executions:
```
task_reschedules = TaskReschedule.find_for_task_instance(
context["ti"], try_number=first_try_number
) # <-- This call is returning an empty list
if not task_reschedules:
start_date = timezone.utcnow()
else:
start_date = task_reschedules[0].start_date
```
Because this list is empty, `start_date` is always `utcnow()`, so it never
fails the timeout check further down:
```
if run_duration() > self.timeout:
# If sensor is in soft fail mode but times out raise
AirflowSkipException.
message = (
f"Sensor has timed out; run duration of {run_duration()}
seconds exceeds "
f"the specified timeout of {self.timeout}."
)
if self.soft_fail:
raise AirflowSkipException(message)
else:
raise AirflowSensorTimeout(message)
```
--
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]
