diff --git a/catalog-rest-service/src/main/resources/json/schema/api/services/ingestionPipelines/createIngestionPipeline.json b/catalog-rest-service/src/main/resources/json/schema/api/services/ingestionPipelines/createIngestionPipeline.json index edbe6d13ea8..f9f4981debd 100644 --- a/catalog-rest-service/src/main/resources/json/schema/api/services/ingestionPipelines/createIngestionPipeline.json +++ b/catalog-rest-service/src/main/resources/json/schema/api/services/ingestionPipelines/createIngestionPipeline.json @@ -28,8 +28,7 @@ }, "loggerLevel": { "description": "Set the logging level for the workflow.", - "$ref": "../../../metadataIngestion/workflow.json#/definitions/logLevels", - "default": "INFO" + "$ref": "../../../metadataIngestion/workflow.json#/definitions/logLevels" }, "service": { "description": "Link to the database service where this database is hosted in.", diff --git a/catalog-rest-service/src/main/resources/json/schema/entity/services/ingestionPipelines/ingestionPipeline.json b/catalog-rest-service/src/main/resources/json/schema/entity/services/ingestionPipelines/ingestionPipeline.json index ab886982c8a..c857b784a10 100644 --- a/catalog-rest-service/src/main/resources/json/schema/entity/services/ingestionPipelines/ingestionPipeline.json +++ b/catalog-rest-service/src/main/resources/json/schema/entity/services/ingestionPipelines/ingestionPipeline.json @@ -168,8 +168,7 @@ }, "loggerLevel": { "description": "Set the logging level for the workflow.", - "$ref": "../../../metadataIngestion/workflow.json#/definitions/logLevels", - "default": "INFO" + "$ref": "../../../metadataIngestion/workflow.json#/definitions/logLevels" }, "deployed": { "description": "Indicates if the workflow has been successfully deployed to Airflow.", diff --git a/openmetadata-airflow-apis/src/openmetadata/workflows/ingestion/common.py b/openmetadata-airflow-apis/src/openmetadata/workflows/ingestion/common.py index 91b035f2c92..1b76f1feded 100644 --- a/openmetadata-airflow-apis/src/openmetadata/workflows/ingestion/common.py +++ b/openmetadata-airflow-apis/src/openmetadata/workflows/ingestion/common.py @@ -35,6 +35,7 @@ from metadata.generated.schema.entity.services.ingestionPipelines.ingestionPipel IngestionPipeline, ) from metadata.generated.schema.metadataIngestion.workflow import ( + LogLevels, OpenMetadataWorkflowConfig, WorkflowConfig, ) @@ -103,7 +104,7 @@ def build_workflow_config_property( :return: WorkflowConfig """ return WorkflowConfig( - loggerLevel=ingestion_pipeline.loggerLevel, + loggerLevel=ingestion_pipeline.loggerLevel or LogLevels.INFO, openMetadataServerConfig=ingestion_pipeline.openMetadataServerConnection, )