diff --git a/ext/scheduler/airflow/__lib.py b/ext/scheduler/airflow/__lib.py
index e02f7c63ae..488b25a197 100644
--- 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: