Skip to content
2 changes: 1 addition & 1 deletion airflow/sensors/base.py
Original file line number Diff line number Diff line change
Expand Up @@ -322,7 +322,7 @@ def run_duration() -> float:
raise AirflowRescheduleException(reschedule_date)
else:
time.sleep(self._get_next_poke_interval(started_at, run_duration, poke_count))
poke_count += 1
poke_count += 1
Comment thread
sanket2000 marked this conversation as resolved.
Outdated
self.log.info("Success criteria met. Exiting.")
return xcom_value

Expand Down