removed debug line in scheduler, thanks Niphlod
This commit is contained in:
@@ -1 +1 @@
|
|||||||
Version 2.00.0 (2012-08-20 10:57:08) dev
|
Version 2.00.0 (2012-08-20 10:58:09) dev
|
||||||
|
|||||||
+3
-3
@@ -109,7 +109,7 @@ HEARTBEAT = 3*SECONDS
|
|||||||
MAXHIBERNATION = 10
|
MAXHIBERNATION = 10
|
||||||
CLEAROUT = '!clear!'
|
CLEAROUT = '!clear!'
|
||||||
|
|
||||||
CALLABLETYPES = (types.LambdaType, types.FunctionType,
|
CALLABLETYPES = (types.LambdaType, types.FunctionType,
|
||||||
types.BuiltinFunctionType,
|
types.BuiltinFunctionType,
|
||||||
types.MethodType, types.BuiltinMethodType)
|
types.MethodType, types.BuiltinMethodType)
|
||||||
|
|
||||||
@@ -187,7 +187,7 @@ def executor(queue,task, out):
|
|||||||
pass
|
pass
|
||||||
def write(self,data):
|
def write(self,data):
|
||||||
self.out_queue.put(data)
|
self.out_queue.put(data)
|
||||||
|
|
||||||
stdout = LogOutput(out)
|
stdout = LogOutput(out)
|
||||||
try:
|
try:
|
||||||
if task.app:
|
if task.app:
|
||||||
@@ -265,7 +265,7 @@ class MetaScheduler(threading.Thread):
|
|||||||
while p.is_alive() and (time.time()-start < task.timeout):
|
while p.is_alive() and (time.time()-start < task.timeout):
|
||||||
if tout:
|
if tout:
|
||||||
try:
|
try:
|
||||||
logging.debug("aaaaaaaaaaaaaa partial output saved")
|
logging.debug(' partial output saved')
|
||||||
db(sr.id==task.run_id).update(output = task_output)
|
db(sr.id==task.run_id).update(output = task_output)
|
||||||
db.commit()
|
db.commit()
|
||||||
except:
|
except:
|
||||||
|
|||||||
Reference in New Issue
Block a user