fix: temporary fix to avoid failing of sensor fast in case of shedule run is not present

Author: sravankorumilli

ext/scheduler/airflow2/resources/__lib.py

@@ -240,7 +240,11 @@ def poke(self, context):
 
         # parse relevant metadata from the job metadata to build the task window
         # TODO this needs to be updated to use optimus get job spec
-        upstream_schedule = self.get_schedule_interval(schedule_time)
+        try:
+            upstream_schedule = self.get_schedule_interval(schedule_time)
+        except Exception as e:
+            self.log.warning("error while fetching upstream schedule :: {}".format(e))
+            return False
 
         last_upstream_schedule_time, _ = self.get_last_upstream_times(
             schedule_time, upstream_schedule)