fix

goto · Sep 4, 2024 · fe4c04a · fe4c04a
1 parent 985462f
commit fe4c04a
Showing 1 changed file with 2 additions and 1 deletion.
diff --git a/ext/scheduler/airflow/__lib.py b/ext/scheduler/airflow/__lib.py
@@ -231,7 +231,8 @@ def poke(self, context):
         replay_config = self._optimus_client.get_job_replay_config(self.project_name, self.name)
         if 'jobConfig' in replay_config.keys():
             if 'IGNORE_UPSTREAM' in replay_config['jobConfig'].keys():
-                return True
+                if replay_config['jobConfig']['IGNORE_UPSTREAM'] == "True":
+                    return True
         try:
             upstream_schedule = self.get_schedule_interval(schedule_time)
         except Exception as e: