Why does airflow skips a day for a daily dag?

Boyu Fang

I have a newly created daily dag and I have set it up yesterday (Jan. 25th), once it is loaded by airflow I can see it is run once (scheduled_2021-0124T00:00:00+00:00), and then I manually triggered it once just to see if it works and it did (manual_2021-01-25).

Now time is 08:24 UTC Jan 26th. But I did not see any run for 01-25. I have used airflow dags next-execution and found out airflow is planning to execute the dag for 01-26 directly, possibly on 01-27 00:00 UTC. So it will skip 01-25 entirely.

I am wondering why this behaviour? Is there any reason behind this?

enter image description here

Boyu Fang

This is actually a bug in Airflow 2.0.0 release which was fixed in 2.0.1: https://github.com/apache/airflow/issues/13434

Collected from the Internet

Please contact [email protected] to delete if infringement.

edited at
0

Comments

0 comments
Login to comment

Related

Why does Airflow ExternalTaskSensor not work on the dag having PythonOperator?

Why does this code to get Airflow context get run on DAG import?

Airflow DAG Runs Daily Excluding Weekends?

Airflow: re execute the jobs of a DAG for the past n days on a daily basis

python - How to configure airflow dag to run twice daily

When does a airflow dag definition get evaluated?

why does lldb skips this line?

does manual triggering of a airflow DAG interfere with the scheduled airflow trigger?

Airflow DAG Scheduling last day of month -n days

Airflow schedule single dag for multiple schedules throughout the day

Unable to make Airflow DAG run at a specific time every day

Airflow: how to schedule a dag to start the day following a weekday?

why does it skips the first line for input of an array

Why does remove() skips every second in array

Why does ftell skips some positions in the file?

why does the app skips the LoginActivity to HomeActivity?

Why does for loop skips the first i++

Why airflow scheduler keeps running my DAG file?

Why is there a DAG named 'airflow_monitoring' automatically generated in Cloud Composer?

Why are my custom operators not being imported into my DAG (Airflow)?

Why only a DummyOperator task can run in my Airflow DAG?

Airflow DAG does not run at specified time with catchup=False

Airflow DAG does not skip tasks after BranchPythonOperator or ShortCircuitOperator

Airflow DAG while parsing, executes the code every 30 seconds, instead of daily

External files in Airflow DAG

Airflow, enable dag on creation

How to restart DAG in Airflow?

Airflow: how to delete a DAG?

Get DAG from airflow