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

Commit e47bd583 authored by Maude Le Jeune's avatar Maude Le Jeune
Browse files

Task #871 closed with queued_on, ended_on ,begun_on and param fields filled

parent 8c3236fb
......@@ -351,12 +351,19 @@ class SqliteTracker(Tracker,threading.Thread):
"""
if status == 'done':
task_output = pickle.dumps(t.task_output)
self._asynchronous_request('update tasks set status=?, output=?, ended_on=? where task_id=?',
(status, task_output, str_date(), t.id))
self._asynchronous_request('update segments set param=? where seg=?',
(t.tag, t.seg))
else:
t.task_output = None
task_output = pickle.dumps(t.task_output)
if status == 'running':
self._asynchronous_request('update tasks set status=?, output=?, begun_on=? where task_id=?',(status, task_output, str_date(), t.id))
else:
self._asynchronous_request('update tasks set status=?, output=? where task_id=?',(status, task_output, t.id))
#TODO tag problem
self._asynchronous_request('update tasks set status=?, output=? where task_id=?',
(status, task_output, t.id))
t.status = status
return t
......
......@@ -97,7 +97,7 @@ class Web:
e = conn.execute('select queued_on from tasks where seg_id=?',(s[0],)).fetchone()
if e is not None and e:
lst.append(e[0])
return lst
return pylab.unique(lst)
@cherrypy.expose
@write_access
......
......@@ -12,15 +12,6 @@ third->fourth
#T.connect('second', ['third', 'fourth'], 'fourth')
#T.compute_hash()
logger = logging.getLogger('scheduler')
logger.setLevel(logging.DEBUG)
formatter = logging.Formatter("%(asctime)s - %(name)s - %(levelname)s - %(message)s")
shandler = logging.StreamHandler(sys.stdout)
shandler.setLevel(logging.DEBUG)
shandler.setFormatter(formatter)
logger.addHandler(shandler)
T = pipeline.Pipeline(S, code_dir=op.abspath('./'), prefix=op.abspath('./'))
T.to_dot('pipeline.dot')
......
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