python - Airflow tasks in queue but never scheduled -
with airflow 1.8.1, using localexecutor max_active_runs_per_dag=16
, called loop dynamic create tasks (~100) pythonoperators. time tasks completed without issues. however, still possible task queue
status scheduler seems forget it, can clear task , able rerun queued task , worked, know how avoid stuck in queue.
Comments
Post a Comment