Update anomaly_detection.py

insight scheduler None bug fix
m-cmp · Nov 14, 2024 · f151338 · f151338
1 parent 29f0896
commit f151338
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/python/scheduler/airflow-home/dags/anomaly_detection.py b/python/scheduler/airflow-home/dags/anomaly_detection.py
@@ -46,7 +46,7 @@ def filter_records_to_execute(records):
 
     for record in records:
         last_execution = record['LAST_EXECUTION']
-        if last_execution == 'NaT':
+        if last_execution == 'None' or last_execution == 'NaT':
             record['LAST_EXECUTION'] = pd.Timestamp('1970-01-01')
         else:
             record['LAST_EXECUTION'] = pd.to_datetime(last_execution)