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

fixed dagster tasks status (#15605)

Browse Source
This commit is contained in:
Onkar Ravgan 2024-03-19 18:03:58 +05:30 committed by GitHub
parent 91184ecf5d
commit 2dd912ab8a
No known key found for this signature in database
GPG Key ID: B5690EEEBB952194
1 changed files with 3 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
ingestion/src/metadata/ingestion/source/pipeline/dagster/metadata.py
View File

@ -216,7 +216,9 @@ class DagsterSource(PipelineServiceSource):
service_name=self.context.pipeline_service, service_name=self.context.pipeline_service,
pipeline_name=self.context.pipeline, 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 []: for task in pipeline_entity.tasks or []:
try: try:
runs = self.client.get_task_runs( runs = self.client.get_task_runs(