iremonur commented on issue #15192:
URL: https://github.com/apache/airflow/issues/15192#issuecomment-813236049
Actually, I tried schedule to another tasks to be 10 minutes between each
other, I want the first task to start at 19:50.
In the dag code (located in ~/airflow/dags/tutorial_v2.py), I set:
-> start_date=datetime.datetime(2021, 4, 4, 19, 50)
-> schedule_interval= '*/10 * * * *'
The first task is succeeded but the other three of them are stuck in the
state of "running".
Some of the parameters I set in the dag code :
default_args = {
'owner': 'airflow',
'depends_on_past': False,
'wait_for_downstream' : False,
'email': ['[email protected]'],
'email_on_failure': False,
'email_on_retry': False,
'retries': 1,
'retry_delay': timedelta(minutes=5),
}
I run these commands to schedule the dag:
$ python ~/airflow/dags/tutorial_v2.py
$ airflow db init
$ airflow dags backfill dag_v6 -s 2021-04-04-19:50 -e 2021-04-06
The tasks which have the execution time at future are succeeded but some of
the tasks at the beginning are stuck in the state of "running" :+1:
I don't understand why the scheduler skip some of the tasks, I would be very
glad if you help me with this.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
For queries about this service, please contact Infrastructure at:
[email protected]
