diff --git a/ingestion/src/metadata/ingestion/source/pipeline/airflow/metadata.py b/ingestion/src/metadata/ingestion/source/pipeline/airflow/metadata.py
index 741f307eafa..71a2ac27138 100644
--- a/ingestion/src/metadata/ingestion/source/pipeline/airflow/metadata.py
+++ b/ingestion/src/metadata/ingestion/source/pipeline/airflow/metadata.py
@@ -313,6 +313,7 @@ class AirflowSource(PipelineServiceSource):
                 else [],
                 startDate=task.start_date.isoformat() if task.start_date else None,
                 endDate=task.end_date.isoformat() if task.end_date else None,
+                taskType=task.task_type,
             )
             for task in cast(Iterable[BaseOperator], dag.tasks)
         ]