Merge pull request #35 from airflow-laminar/tkp/poke

use poke instead of reschedule
airflow-laminar · Aug 24, 2024 · b9694cc · b9694cc
2 parents 6332dba + 8ea2eba
commit b9694cc
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/airflow_supervisor/airflow/local.py b/airflow_supervisor/airflow/local.py
@@ -219,7 +219,7 @@ def get_step_operator(self, step: SupervisorTaskStep) -> Operator:
                     "task_id": f"{self.dag_id}-{step}",
                     "poke_interval": self._supervisor_cfg.check_interval.total_seconds(),
                     "timeout": self._supervisor_cfg.check_timeout.total_seconds(),
-                    "mode": "reschedule",
+                    "mode": "poke",
                     **self.get_base_operator_kwargs(),
                     **self.get_step_kwargs(step),
                 }