From 11aca93a5a702e82c123daf87cd4c8b06c0cb3a7 Mon Sep 17 00:00:00 2001 From: Ephraim Anierobi Date: Wed, 10 Aug 2022 13:31:32 +0100 Subject: [PATCH] Update airflow/ti_deps/deps/ready_to_reschedule.py Co-authored-by: Tzu-ping Chung --- airflow/ti_deps/deps/ready_to_reschedule.py | 4 +++- 1 file changed, 3 insertions(+), 1 deletion(-) 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