поток воздуха max_active_run не увеличивается
#airflow-scheduler #airflow Вопрос: мой код dag dag = DAG( "ETL_s21_{}_impression_product_test".format("every_minute"), default_args=default_args, schedule_interval="* * * * *", max_active_runs=10, concurrency=5 ) def export_impression_log(table, item): export_impression_log_task = PythonOperator( task_id=f"{table}_{item}_export_impression_log", python_callable=S3.export_impression_log_from_ad_s3, op_kwargs={ "execution_date": '{{execution_date.in_timezone("Asia/Seoul").strftime("%Y-%m-%d-%H-%M")}}',…