diff --git a/openmetadata-airflow-apis/openmetadata_managed_apis/workflows/ingestion/common.py b/openmetadata-airflow-apis/openmetadata_managed_apis/workflows/ingestion/common.py index 1b6e001f61e5..8f5b67b07af1 100644 --- 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)