Docker-in-Docker (DinD) capabilities of public runners deactivated. More info

Commit bf455f57 authored by Betoule Marc's avatar Betoule Marc
Browse files

suppress performance hurting debug messages

parent 7c26bbe9
......@@ -244,21 +244,21 @@ class Scheduler():
logger.info('Found %d tasks in seg %s to get done'%(len(l),seg))
for t in l: # foreach task of the task list
if (t.task_input in failed_prod): # done but failed
logger.debug("task already done and failed in seg %s"%seg)
#logger.debug("task already done and failed in seg %s"%seg)
continue
if not (t.task_input in dprod): # not done
logger.debug("pushing 1 task for seg %s"%seg)
#logger.debug("pushing 1 task for seg %s"%seg)
self.put_task(t)
else: # done
logger.debug("task already accomplished in segment %s"%seg)
# fetch the result of the task and store it in the task list
#logger.debug("task already accomplished in segment %s"%seg)
# fetch the result of the task and store it in the task list
ind = dprod.index(t.task_input)
t = d[ind];
try:
logger.debug("Loading %d results from previously done task in segment %s"%(len(t.task_output),seg))
except TypeError:
logger.debug("No result to load from previously done task in segment %s"%(seg))
#try:
#logger.debug("Loading %d results from previously done task in segment %s"%(len(t.task_output),seg))
#except TypeError:
#logger.debug("No result to load from previously done task in segment %s"%(seg))
self.products_list.push(t)
self.nb_success = self.nb_success + 1
......@@ -311,8 +311,12 @@ class Scheduler():
self.task_queue.task_done()
except Queue.Empty:
logger.debug("Empty Queue")
def run(self):
#import cProfile
#cProfile.runctx('self._run()', globals(), locals(),'schedprof')
#def _run(self):
""" Start the scheduler.
Start a tracker and fill the task queue with the first segment task.
......
Markdown is supported
0% or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment