diff --git a/beat/web/backend/schedule.py b/beat/web/backend/schedule.py index 72d88b2c280c18b19a435f090249b4b2c2ca4deb..e8fc2fa71b2d23e9add96c5a9b72ac95e5d1b345 100644 --- a/beat/web/backend/schedule.py +++ b/beat/web/backend/schedule.py @@ -190,8 +190,7 @@ def schedule(): if not any(splits_to_consider): return [] - logger.debug('Ordered queues: %s', - ','.join([k.name for k in sorted_queues])) + logger.debug('Considering splits: %s', splits_to_consider) # decides which split to run considering the 'on-the-fly' availability @@ -204,6 +203,8 @@ def schedule(): assigned_splits = [] + logger.debug('Worker availability: %s', whitelist) + for batch in splits_to_consider: if not batch: continue #empty list @@ -218,7 +219,7 @@ def schedule(): avail = whitelist.get(c, 0) if not avail: continue #should not use this worker if avail >= required_cores: - logger.info("Assigning `%s' to worker `%s'", split, c) + logger.debug("Assigning `%s' to worker `%s'", split, c) split.schedule(c) #assign job split to worker assigned_splits.append(split) whitelist[c] -= required_cores