diff --git a/ingestion/src/metadata/ingestion/source/pipeline/airflow/metadata.py b/ingestion/src/metadata/ingestion/source/pipeline/airflow/metadata.py
index a3b920ac26e..ed728b98cf0 100644
--- a/ingestion/src/metadata/ingestion/source/pipeline/airflow/metadata.py
+++ b/ingestion/src/metadata/ingestion/source/pipeline/airflow/metadata.py
@@ -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()
             )