Я тестирую параметр end_date
на уровне_задачи, но кажется, что как только одна задача end_date
удовлетворена, другие задачи также прекращаются. Ниже приведен пример кода:
default_args = {'owner': 'xyz', 'depends_on_past': False,}
with DAG('dag', default_args=default_args, schedule_interval='@daily', catchup=True) as dag:
bash_end = BashOperator(
task_id='bash_end',
bash_command='echo {{ ds }}',
start_date=datetime(2020, 3, 1),
end_date=datetime(2020, 3, 5)
)
bash_no_end = BashOperator(
task_id='bash_no_end',
bash_command='echo {{ ds }}',
start_date=datetime(2020, 3, 3),
)
В приведенном выше примере start_date
работает отлично, но после 2020-03-05 даже bash_no_end
не запланировано. Ожидается ли такое поведение?