diff --git a/openmetadata-airflow-apis/openmetadata_managed_apis/operations/deploy.py b/openmetadata-airflow-apis/openmetadata_managed_apis/operations/deploy.py index 5996bfa98226..d0339bc0c26d 100644 --- a/openmetadata-airflow-apis/openmetadata_managed_apis/operations/deploy.py +++ b/openmetadata-airflow-apis/openmetadata_managed_apis/operations/deploy.py @@ -74,7 +74,9 @@ def store_airflow_pipeline_config( logger.info(f"Saving file to {dag_config_file_path}") with open(dag_config_file_path, "w") as outfile: - outfile.write(self.ingestion_pipeline.model_dump_json()) + outfile.write( + self.ingestion_pipeline.model_dump_json(exclude_defaults=False) + ) return {"workflow_config_file": str(dag_config_file_path)} diff --git a/openmetadata-airflow-apis/openmetadata_managed_apis/workflows/ingestion/application.py b/openmetadata-airflow-apis/openmetadata_managed_apis/workflows/ingestion/application.py index 99678759f1f5..2e344a064441 100644 --- a/openmetadata-airflow-apis/openmetadata_managed_apis/workflows/ingestion/application.py +++ b/openmetadata-airflow-apis/openmetadata_managed_apis/workflows/ingestion/application.py @@ -49,7 +49,7 @@ def application_workflow(workflow_config: OpenMetadataApplicationConfig): set_operator_logger(workflow_config) - config = json.loads(workflow_config.model_dump_json()) + config = json.loads(workflow_config.model_dump_json(exclude_defaults=False)) workflow = ApplicationWorkflow.create(config) workflow.execute() diff --git a/openmetadata-airflow-apis/openmetadata_managed_apis/workflows/ingestion/data_insight.py b/openmetadata-airflow-apis/openmetadata_managed_apis/workflows/ingestion/data_insight.py index 820654160a03..d180e0896259 100644 --- a/openmetadata-airflow-apis/openmetadata_managed_apis/workflows/ingestion/data_insight.py +++ b/openmetadata-airflow-apis/openmetadata_managed_apis/workflows/ingestion/data_insight.py @@ -58,7 +58,7 @@ def data_insight_workflow(workflow_config: OpenMetadataWorkflowConfig): """ set_operator_logger(workflow_config) - config = json.loads(workflow_config.model_dump_json()) + config = json.loads(workflow_config.model_dump_json(exclude_defaults=False)) workflow = DataInsightWorkflow.create(config) workflow.execute() diff --git a/openmetadata-airflow-apis/openmetadata_managed_apis/workflows/ingestion/profiler.py b/openmetadata-airflow-apis/openmetadata_managed_apis/workflows/ingestion/profiler.py index 62822387961c..891460368298 100644 --- a/openmetadata-airflow-apis/openmetadata_managed_apis/workflows/ingestion/profiler.py +++ b/openmetadata-airflow-apis/openmetadata_managed_apis/workflows/ingestion/profiler.py @@ -43,7 +43,7 @@ def profiler_workflow(workflow_config: OpenMetadataWorkflowConfig): set_operator_logger(workflow_config) - config = json.loads(workflow_config.model_dump_json()) + config = json.loads(workflow_config.model_dump_json(exclude_defaults=False)) workflow = ProfilerWorkflow.create(config) workflow.execute() diff --git a/openmetadata-airflow-apis/openmetadata_managed_apis/workflows/ingestion/test_suite.py b/openmetadata-airflow-apis/openmetadata_managed_apis/workflows/ingestion/test_suite.py index 37d5d4314e2a..38263010e92b 100644 --- a/openmetadata-airflow-apis/openmetadata_managed_apis/workflows/ingestion/test_suite.py +++ b/openmetadata-airflow-apis/openmetadata_managed_apis/workflows/ingestion/test_suite.py @@ -43,7 +43,7 @@ def test_suite_workflow(workflow_config: OpenMetadataWorkflowConfig): set_operator_logger(workflow_config) - config = json.loads(workflow_config.model_dump_json()) + config = json.loads(workflow_config.model_dump_json(exclude_defaults=False)) workflow = TestSuiteWorkflow.create(config) workflow.execute() diff --git a/openmetadata-airflow-apis/openmetadata_managed_apis/workflows/ingestion/usage.py b/openmetadata-airflow-apis/openmetadata_managed_apis/workflows/ingestion/usage.py index 77f71281c4ed..e4094f2d02e0 100644 --- a/openmetadata-airflow-apis/openmetadata_managed_apis/workflows/ingestion/usage.py +++ b/openmetadata-airflow-apis/openmetadata_managed_apis/workflows/ingestion/usage.py @@ -47,7 +47,7 @@ def usage_workflow(workflow_config: OpenMetadataWorkflowConfig): set_operator_logger(workflow_config) - config = json.loads(workflow_config.model_dump_json()) + config = json.loads(workflow_config.model_dump_json(exclude_defaults=False)) workflow = UsageWorkflow.create(config) workflow.execute()