Skip to content

Commit

Permalink
Update airflow/ti_deps/deps/ready_to_reschedule.py
Browse files Browse the repository at this point in the history
Co-authored-by: Tzu-ping Chung <uranusjr@gmail.com>
  • Loading branch information
ephraimbuddy and uranusjr committed Aug 10, 2022
1 parent 6235c94 commit 11aca93
Showing 1 changed file with 3 additions and 1 deletion.
4 changes: 3 additions & 1 deletion airflow/ti_deps/deps/ready_to_reschedule.py
Expand Up @@ -42,7 +42,9 @@ def _get_dep_statuses(self, ti, session, dep_context):
"""
is_mapped = ti.task.is_mapped
if not is_mapped and not getattr(ti.task, "reschedule", False):
# Mapped sensors don't currently have the reschedule property,
# Mapped sensors don't have the reschedule property (it can only
# be calculated after unmapping), so we don't check them here.
# They are handled below by checking TaskReschedule instead.
yield self._passing_status(reason="Task is not in reschedule mode.")
return

Expand Down

0 comments on commit 11aca93

Please sign in to comment.