From 693fe66f633eaf6a5ab7a318881e569cde82b48d Mon Sep 17 00:00:00 2001
From: Andre Anjos <andre.anjos@idiap.ch>
Date: Fri, 20 May 2016 12:05:49 +0200
Subject: [PATCH] [backend] Print more debugging info for the scheduler
---
beat/web/backend/schedule.py | 7 ++++---
1 file changed, 4 insertions(+), 3 deletions(-)
diff --git a/beat/web/backend/schedule.py b/beat/web/backend/schedule.py
index 72d88b2c2..e8fc2fa71 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
--
GitLab