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

Popular posts from this blog

Is there a better way to structure post methods in Class Based Views -

reflection - How to access the object-members of an object declaration in kotlin -

php - Doctrine Query Builder Error on Join: [Syntax Error] line 0, col 87: Error: Expected Literal, got 'JOIN' -