scheduler patch, thanks Niphlod
This commit is contained in:
@@ -1 +1 @@
|
|||||||
Version 2.4.1-alpha.2+timestamp.2013.01.15.13.25.43
|
Version 2.4.1-alpha.2+timestamp.2013.01.15.15.53.29
|
||||||
|
|||||||
+2
-1
@@ -556,7 +556,7 @@ class Scheduler(MetaScheduler):
|
|||||||
self.die()
|
self.die()
|
||||||
|
|
||||||
def wrapped_assign_tasks(self, db):
|
def wrapped_assign_tasks(self, db):
|
||||||
db.commit() # ?don't know if it's useful, let's be completely sure
|
db.commit() #db.commit() only for Mysql
|
||||||
x = 0
|
x = 0
|
||||||
while x < 10:
|
while x < 10:
|
||||||
try:
|
try:
|
||||||
@@ -571,6 +571,7 @@ class Scheduler(MetaScheduler):
|
|||||||
|
|
||||||
def wrapped_pop_task(self):
|
def wrapped_pop_task(self):
|
||||||
db = self.db
|
db = self.db
|
||||||
|
db.commit() #another nifty db.commit() only for Mysql
|
||||||
x = 0
|
x = 0
|
||||||
while x < 10:
|
while x < 10:
|
||||||
try:
|
try:
|
||||||
|
|||||||
Reference in New Issue
Block a user