Fix model_dump_json for all pipelines

open-metadata · Jun 20, 2024 · 1f6250a · 1f6250a
1 parent 9bdfbc2
commit 1f6250a
Show file tree

Hide file tree

Showing 4 changed files with 4 additions and 4 deletions.
diff --git 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
@@ -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/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
@@ -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()