push_task = PythonOperator(task_id='pushing_task', provide_context=True,
    python_callable=pushing_task, trigger_rule='all_done', dag=dag)
Правильный способ создания динамических рабочих процессов в Airflow