yujunjun/OpenMetadata
1
0
Fork 0
mirror of https://github.com/open-metadata/OpenMetadata.git synced 2025-09-27 09:55:36 +00:00
Code Issues Packages Projects Releases Wiki Activity

[fixed] profiler would not fetch serivceConnection from OpenMetadata server when serviceConnection was omitted from workflow YAML (#10335)

Browse Source
This commit is contained in:
Austin Witt 2023-02-25 12:11:49 -06:00 committed by GitHub
parent f38295ec11
commit 2d65cf02b0
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
1 changed files with 2 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
ingestion/src/metadata/orm_profiler/api/workflow.py
View File

@ -113,8 +113,8 @@ class ProfilerWorkflow(WorkflowStatusMixin):
self.config.processor.dict().get("config") self.config.processor.dict().get("config")
) )
self.metadata = OpenMetadata(self.metadata_config) self.metadata = OpenMetadata(self.metadata_config)
self.test_connection()
self._retrieve_service_connection_if_needed() self._retrieve_service_connection_if_needed()
self.test_connection()
self.set_ingestion_pipeline_status(state=PipelineState.running) self.set_ingestion_pipeline_status(state=PipelineState.running)
# Init and type the source config # Init and type the source config
self.source_config: DatabaseServiceProfilerPipeline = cast( self.source_config: DatabaseServiceProfilerPipeline = cast(
@ -564,7 +564,7 @@ class ProfilerWorkflow(WorkflowStatusMixin):
service_type: ServiceType = get_service_type_from_source_type( service_type: ServiceType = get_service_type_from_source_type(
self.config.source.type self.config.source.type
) )
if self.config.source.serviceConnection: if not self.config.source.serviceConnection:
service_name = self.config.source.serviceName service_name = self.config.source.serviceName
try: try:
service: ServiceWithConnectionType = cast( service: ServiceWithConnectionType = cast(