yujunjun/OpenMetadata
1
0
Fork 0
mirror of https://github.com/open-metadata/OpenMetadata.git synced 2025-12-06 20:47:26 +00:00
Code Issues Packages Projects Releases Wiki Activity

Fix #5379 - Fix service type handling on REST APIs (#5380)

Browse Source
This commit is contained in:
Pere Miquel Brull 2022-06-08 20:36:10 +02:00 committed by GitHub
parent e851242a1a
commit 3cbd0bc1d8
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
1 changed files with 4 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

8
openmetadata-airflow-apis/src/openmetadata/workflows/ingestion/common.py
View File

@ -71,13 +71,13 @@ def build_source(ingestion_pipeline: IngestionPipeline) -> WorkflowSource:
entity=PipelineService, fqn=ingestion_pipeline.service.name entity=PipelineService, fqn=ingestion_pipeline.service.name
) )
elif service_type == "dashboardService": elif service_type == "dashboardService":
service: MessagingService = metadata.get_by_name(
entity=MessagingService, fqn=ingestion_pipeline.service.name
)
elif service_type == "messagingService":
service: DashboardService = metadata.get_by_name( service: DashboardService = metadata.get_by_name(
entity=DashboardService, fqn=ingestion_pipeline.service.name entity=DashboardService, fqn=ingestion_pipeline.service.name
) )
elif service_type == "messagingService":
service: MessagingService = metadata.get_by_name(
entity=MessagingService, fqn=ingestion_pipeline.service.name
)
if not service: if not service:
raise ValueError(f"Could not get service from type {service_type}") raise ValueError(f"Could not get service from type {service_type}")