From 2dd912ab8a057decbc9b93270d77b2cdbfe7a5c1 Mon Sep 17 00:00:00 2001 From: Onkar Ravgan Date: Tue, 19 Mar 2024 18:03:58 +0530 Subject: [PATCH] fixed dagster tasks status (#15605) --- .../metadata/ingestion/source/pipeline/dagster/metadata.py | 4 +++- 1 file changed, 3 insertions(+), 1 deletion(-) diff --git a/ingestion/src/metadata/ingestion/source/pipeline/dagster/metadata.py b/ingestion/src/metadata/ingestion/source/pipeline/dagster/metadata.py index ff5436ca2e7..10ce959cef0 100644 --- a/ingestion/src/metadata/ingestion/source/pipeline/dagster/metadata.py +++ b/ingestion/src/metadata/ingestion/source/pipeline/dagster/metadata.py @@ -216,7 +216,9 @@ class DagsterSource(PipelineServiceSource): service_name=self.context.pipeline_service, pipeline_name=self.context.pipeline, ) - pipeline_entity = self.metadata.get_by_name(entity=Pipeline, fqn=pipeline_fqn) + pipeline_entity = self.metadata.get_by_name( + entity=Pipeline, fqn=pipeline_fqn, fields=["tasks"] + ) for task in pipeline_entity.tasks or []: try: runs = self.client.get_task_runs(