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

angular - DownloadURL return null in below code -

python 2.7 - Given three nested dictionaries, sort the top two nested dictionaries from a value in the innermost dictionary? -