Skip to content
Snippets Groups Projects
Commit 693fe66f authored by André Anjos's avatar André Anjos :speech_balloon:
Browse files

[backend] Print more debugging info for the scheduler

parent 4a213a9d
No related branches found
No related tags found
1 merge request!194Scheduler
Pipeline #
...@@ -190,8 +190,7 @@ def schedule(): ...@@ -190,8 +190,7 @@ def schedule():
if not any(splits_to_consider): return [] if not any(splits_to_consider): return []
logger.debug('Ordered queues: %s', logger.debug('Considering splits: %s', splits_to_consider)
','.join([k.name for k in sorted_queues]))
# decides which split to run considering the 'on-the-fly' availability # decides which split to run considering the 'on-the-fly' availability
...@@ -204,6 +203,8 @@ def schedule(): ...@@ -204,6 +203,8 @@ def schedule():
assigned_splits = [] assigned_splits = []
logger.debug('Worker availability: %s', whitelist)
for batch in splits_to_consider: for batch in splits_to_consider:
if not batch: continue #empty list if not batch: continue #empty list
...@@ -218,7 +219,7 @@ def schedule(): ...@@ -218,7 +219,7 @@ def schedule():
avail = whitelist.get(c, 0) avail = whitelist.get(c, 0)
if not avail: continue #should not use this worker if not avail: continue #should not use this worker
if avail >= required_cores: 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 split.schedule(c) #assign job split to worker
assigned_splits.append(split) assigned_splits.append(split)
whitelist[c] -= required_cores whitelist[c] -= required_cores
......
0% Loading or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment