diff --git a/airflow/ti_deps/deps/ready_to_reschedule.py b/airflow/ti_deps/deps/ready_to_reschedule.py index a3f7ab59b7aa7..88219bb401dca 100644 --- a/airflow/ti_deps/deps/ready_to_reschedule.py +++ b/airflow/ti_deps/deps/ready_to_reschedule.py @@ -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