space cleanup

This commit is contained in:
mdipierro
2019-02-17 17:20:38 -08:00
parent bf23e7bb0e
commit f06c60b963
23 changed files with 27 additions and 38 deletions
+2 -2
View File
@@ -1367,7 +1367,7 @@ class Scheduler(MetaScheduler):
ws = wkgroups.get(gname)
if ws:
if task.broadcast:
for worker in ws['workers']:
for worker in ws['workers']:
new_task = db.scheduler_task.insert(
application_name = task.application_name,
task_name = task.task_name,
@@ -1389,7 +1389,7 @@ class Scheduler(MetaScheduler):
db(st.id == task.id).update(times_run=task.times_run+1,
next_run_time=next_run_time,
last_run_time=now)
db.commit()
db.commit()
else:
counter = 0
myw = 0