Hi,

Our team uses Airflow extensively and we stumbled on an issue that might
need some help understanding the interplay between scheduler and worker.

Let's say I wrote a test_dag.py in the dags sub dir and it simply downloads
a file from S3 which contains a list of strings. Now, I create a linear DAG
where each task is simply printing a string. These tasks are in the order
they appear in the file.

How may times does the file exactly be downloaded for a dag run?


Thanks,
Satya

Reply via email to