Воздушный поток - уровень задачи end_date не работает - PullRequest
1 голос
/ 12 марта 2020

Я тестирую параметр 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 не запланировано. Ожидается ли такое поведение?

Добро пожаловать на сайт PullRequest, где вы можете задавать вопросы и получать ответы от других членов сообщества.
...