yujunjun/OpenMetadata
1
0
Fork 0
mirror of https://github.com/open-metadata/OpenMetadata.git synced 2025-09-25 17:04:54 +00:00
Code Issues Packages Projects Releases Wiki Activity

Airflow add task type during ingestion (#12310)

Browse Source
This commit is contained in:
Mayur Singal 2023-07-19 00:30:48 +05:30 committed by GitHub
parent b699acd900
commit e79067d69a
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
1 changed files with 1 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

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

@ -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)
]