diff --git a/ingestion/src/metadata/ingestion/source/pipeline/airflow/metadata.py b/ingestion/src/metadata/ingestion/source/pipeline/airflow/metadata.py
index f5a060e9cf1a..13f8d105a4b4 100644
--- a/ingestion/src/metadata/ingestion/source/pipeline/airflow/metadata.py
+++ b/ingestion/src/metadata/ingestion/source/pipeline/airflow/metadata.py
@@ -75,7 +75,7 @@ class OMTaskInstance(BaseModel):
     """
 
     task_id: str
-    state: str
+    state: Optional[str]
     start_date: Optional[datetime]
     end_date: Optional[datetime]