From e79067d69adca08a22f2699ec15044c55c54a075 Mon Sep 17 00:00:00 2001 From: Mayur Singal <39544459+ulixius9@users.noreply.github.com> Date: Wed, 19 Jul 2023 00:30:48 +0530 Subject: [PATCH] Airflow add task type during ingestion (#12310) --- .../src/metadata/ingestion/source/pipeline/airflow/metadata.py | 1 + 1 file changed, 1 insertion(+) 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) ]