diff --git a/beat/web/backend/schedule.py b/beat/web/backend/schedule.py index 8b5c306b080ea99203870f861d0a4c3e62af0e01..5c01231366cf60f211fce3aec34d5e7fe195e849 100644 --- a/beat/web/backend/schedule.py +++ b/beat/web/backend/schedule.py @@ -196,12 +196,14 @@ def schedule(): sorted_queues = Queue.objects.order_by('-cores_per_slot', 'max_slots_per_user') - logger.debug('Ordered queues: %s', - ','.join([k.name for k in sorted_queues])) - splits_to_consider = \ [_select_splits_for_queue(q) for q in sorted_queues] + if not any(splits_to_consider): return [] + + logger.debug('Ordered queues: %s', + ','.join([k.name for k in sorted_queues])) + # decides which split to run considering the 'on-the-fly' availability # workers that can run job splits