fixed context for multiprocessing in queueManager
@@ -222,7 +222,7 @@ class QueueManager:
"""
if not self.busy[0]:
self.busy[0] = True
- process = mp.Process(target=self._execute_and_update)
+ process = mp.Process(target=_execute_and_update, args=(self,))
process.start()
print("starting "+self.running[0])
self.process.append(process.pid)
@@ -363,3 +363,7 @@ class QueueManager:
"""
self.order[:]=[]
self.order.extend(newOrder)
+
+
+def _execute_and_update(queuemanager):
+ queuemanager._execute_and_update()
