From 2d65cf02b0841a741ce19346ed41ba202b6db824 Mon Sep 17 00:00:00 2001 From: Austin Witt <102046570+awittzb@users.noreply.github.com> Date: Sat, 25 Feb 2023 12:11:49 -0600 Subject: [PATCH] [fixed] profiler would not fetch serivceConnection from OpenMetadata server when serviceConnection was omitted from workflow YAML (#10335) --- ingestion/src/metadata/orm_profiler/api/workflow.py | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/ingestion/src/metadata/orm_profiler/api/workflow.py b/ingestion/src/metadata/orm_profiler/api/workflow.py index 28fac6758db..5f923c47dea 100644 --- a/ingestion/src/metadata/orm_profiler/api/workflow.py +++ b/ingestion/src/metadata/orm_profiler/api/workflow.py @@ -113,8 +113,8 @@ class ProfilerWorkflow(WorkflowStatusMixin): self.config.processor.dict().get("config") ) self.metadata = OpenMetadata(self.metadata_config) - self.test_connection() self._retrieve_service_connection_if_needed() + self.test_connection() self.set_ingestion_pipeline_status(state=PipelineState.running) # Init and type the source config self.source_config: DatabaseServiceProfilerPipeline = cast( @@ -564,7 +564,7 @@ class ProfilerWorkflow(WorkflowStatusMixin): service_type: ServiceType = get_service_type_from_source_type( self.config.source.type ) - if self.config.source.serviceConnection: + if not self.config.source.serviceConnection: service_name = self.config.source.serviceName try: service: ServiceWithConnectionType = cast(