How to Pass Data Between Tasks in Airflow

preview_player
Показать описание
In this video I'll go through ever possible way I know of to pass data between tasks, whether they are Traditional Operators or TaskFlow API Tasks! Check out the repo below if you want code examples for any of these methods!

Рекомендации по теме
Комментарии
Автор

If you have a DAG A that triggers DAG B via-Datasets, can DAG B get information from DAG A? such as run_id or other custom information, like for example, DAG A's Task1 proccessed CSV files [example1.csv, example2.csv[

kazaki
Автор

hi George, nice video
I am looking for a way to pass an json, yaml or some way to pass the configurations to dag.
And then should be able to read those values, overwrite in task and then get the updated value of that variable/config in another task of same dag
However I dont want to use xcom or variables. Is there any way to handle this? PLease let me know

thepakcolapcar
Автор

How can I pass a csv (small) between tasks?

ornachshon