Fix typo in comment in prioritize_queued method

drincruz · Apr 7, 2016 · f509ac6 · f509ac6
1 parent 8558cbd
commit f509ac6
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/airflow/jobs.py b/airflow/jobs.py
@@ -603,7 +603,7 @@ def prioritize_queued(self, session, executor, dagbag):
         for pool, tis in list(d.items()):
             if not pool:
                 # Arbitrary:
-                # If queued outside of a pool, trigger no more than 32 per run
+                # If queued outside of a pool, trigger no more than 128 per run
                 open_slots = 128
             else:
                 open_slots = pools[pool].open_slots(session=session)