revert datetime aware

open-metadata · Jun 6, 2024 · 2e45ce5 · 2e45ce5
1 parent dbcbba3
commit 2e45ce5
Showing 1 changed file with 1 addition and 3 deletions.
diff --git a/openmetadata-airflow-apis/openmetadata_managed_apis/workflows/ingestion/common.py b/openmetadata-airflow-apis/openmetadata_managed_apis/workflows/ingestion/common.py
@@ -247,9 +247,7 @@ def build_dag_configs(ingestion_pipeline: IngestionPipeline) -> dict:
     """
 
     if ingestion_pipeline.airflowConfig.startDate:
-        start_date = datetime.strptime(
-            ingestion_pipeline.airflowConfig.startDate.root, "%Y-%m-%dT%H:%M:%S.%fZ"
-        ).replace(tzinfo=None)
+        start_date = ingestion_pipeline.airflowConfig.startDate.root
     else:
         start_date = datetime.now() - timedelta(days=1)