yujunjun/OpenMetadata
1
0
Fork 0
mirror of https://github.com/open-metadata/OpenMetadata.git synced 2025-12-25 14:38:29 +00:00
Code Issues Packages Projects Releases Wiki Activity

ISSUE-14742: Adjusting metadata.py to filter by enum value (#14884)

Browse Source
This commit is contained in:
Marco Rezende 2024-01-26 02:30:05 -04:00 committed by GitHub
parent c1d62186df
commit 37d967013b
No known key found for this signature in database
GPG Key ID: B5690EEEBB952194
1 changed files with 1 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
ingestion/src/metadata/ingestion/source/pipeline/airflow/metadata.py
View File

@ -192,7 +192,7 @@ class AirflowSource(PipelineServiceSource):
TaskInstance.dag_id == dag_id,
TaskInstance.run_id == run_id,
# updating old runs flag deleted tasks as `removed`
TaskInstance.state != AirflowTaskStatus.REMOVED,
TaskInstance.state != AirflowTaskStatus.REMOVED.value,
)
.all()
)