Changeset 112 for projects/AsynQueue/trunk/asynqueue/base.py

Timestamp:

11/26/07 16:30:56 (1 year ago)

Author:

edsuom

Message:

Task reassignment after disconnections is working and tested, and a timeout feature has been added to allow any stray tasks that got lost in space after a disconnect to be retried

Files:

• projects/AsynQueue/trunk/asynqueue/base.py (modified) (4 diffs)

projects/AsynQueue/trunk/asynqueue/base.py

@@ -189 +189 @@
-                    break
-                wfd = defer.waitForDeferred(self.mgr.assignment(task))
-
+; wfd.getResult()
-            # Clean up after the loop exits
-            wfd = defer.waitForDeferred(self.mgr.shutdown(self.timeout))
@@ -195 +195 @@
-            self.heap.shutdown()
-            # The result of the runner is a list of any unfinished tasks.
-
+
+
+
+
+
+
-        
-        if self.isRunning():
@@ -248 +253 @@
-            if worker == workerOrID:
-                return thisID
-        raise ValueError("No such worker")
-    
-    def detachWorker(self, workerOrID, reassign=False, crash=False):
@@ -261 +265 @@
-        See L{tasks.WorkerManager.terminate}.
-        """
-        def terminated(unfinishedTasks):
-            for task in unfinishedTasks:
-                self.mgr.assignment(task)
-
-        ID = self._getWorkerID(workerOrID)
+        if ID is None:
+            return
-        if crash:
-
+, reassign=reassign
-        else:
-
-
-
+
-        return d
-