yujunjun/OpenMetadata
1
0
Fork 0
mirror of https://github.com/open-metadata/OpenMetadata.git synced 2025-08-05 15:48:03 +00:00
Code Issues Packages Projects Releases Wiki Activity

Fix Airflow ingestion: check if downstream task are null (#11539)

Browse Source 
* Fix Airflow ingestion: check if downstream task are null

* Fix Airflow ingestion: check if downstream task are null
This commit is contained in:
Sriharsha Chintalapani 2023-05-10 21:43:57 -07:00 committed by GitHub
parent b0764aa7dd
commit e3a99e2f84
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
1 changed files with 3 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

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

@ -313,7 +313,9 @@ class AirflowSource(PipelineServiceSource):
f"{clean_uri(host_port)}/taskinstance/list/"
f"?flt1_dag_id_equals={dag.dag_id}&_flt_3_task_id={task.task_id}"
),
downstreamTasks=list(task.downstream_task_ids),
downstreamTasks=list(task.downstream_task_ids)
if task.downstream_task_ids
else [],
startDate=task.start_date.isoformat() if task.start_date else None,
endDate=task.end_date.isoformat() if task.end_date else None,
)