scheduler patch, thanks dupak

This commit is contained in:
Massimo DiPierro
2011-11-25 21:47:40 -06:00
parent bfed18611b
commit e3534136e6
2 changed files with 3 additions and 2 deletions
+1 -1
View File
@@ -1 +1 @@
Version 1.99.3 (2011-11-25 21:44:35) dev
Version 1.99.3 (2011-11-25 21:47:39) dev
+2 -1
View File
@@ -378,6 +378,7 @@ class Scheduler(MetaScheduler):
assigned_worker_name=self.worker_name,status=ASSIGNED)
db.commit()
except:
number_grabbed = None
db.rollback()
if number_grabbed:
logging.debug(' grabbed %s tasks' % number_grabbed)
@@ -527,7 +528,7 @@ def main():
tasks = {}
group_names = [x.strip() for x in options.group_names.split(',')]
logging.getLogger().setLevel(logging.DEBUG)
logging.getLogger().setLevel(options.logger_level)
print 'groups for this worker: '+', '.join(group_names)
print 'connecting to database in folder: ' + options.db_folder or './'