Changeset 103

Timestamp:

11/19/07 22:35:05 (1 year ago)

Author:

edsuom

Message:

Now can line up multiple update calls per job

Files:

• projects/AsynQueue/trunk/asynqueue/jobs.py (modified) (2 diffs)
• projects/AsynQueue/trunk/asynqueue/test/test_jobs.py (modified) (3 diffs)

projects/AsynQueue/trunk/asynqueue/jobs.py

@@ -169 +169 @@
-    instantiate my own if not.
-
+    I maintain a dict I{updates} of update tasks to perform for each jobID
+    before any (further) runs for that job. Each sequence has four elements::
+
+        [funcName, args, kw, workersUpdated]
+
+    When a worker runs a given update task, that worker's ID is appended to the
+    I{workersUpdate} list that is the fourth element of I{updates}. That will
+    indicate that it needs not run the update task again.
+
-    @ivar queue: The TaskQueue instance I'm using.
-    
@@ -286 +295 @@
-
-    def _runUpdate(self, jobID, worker):
-
-
-
+
+
+
+
+
+
+
+
+
-    def update(self, jobID, callName, *args, **kw):
-        """
-
-
+
+
+
+
+
+
-        dList = [
-
-
+
-        return defer.DeferredList(dList)
-    

projects/AsynQueue/trunk/asynqueue/test/test_jobs.py

@@ -37 +37 @@
-    return G
-
+def total():
+    return sum(G)
+
-def test(a, b, c=0):
-    return a + 2*b + 3*c
@@ -54 +57 @@
-        result = self.root.remote_newJob(JOB_ID, JOB_CODE)
-        self.failUnlessEqual(result[0], True)
-
+
+
-    
-    def test_newJob_bogus(self):
@@ -217 +221 @@
-        return d
-
+    def test_run_updates(self):
+        def gotJobID(jobID):
+            d = self.mgr.update(jobID, 'setup', 1)
+            d.addCallback(lambda _: self.mgr.update(jobID, 'setup', 2))
+            d.addCallback(lambda _: self.mgr.run(jobID, 'total'))
+            d.addCallback(self.failUnlessEqual, 3)
+            return d
+        
+        d = self._attach()
+        d.addCallback(lambda _: self.mgr.new(JOB_CODE))
+        d.addCallback(gotJobID)
+        return d
+
-    def test_run_one(self):
-        d = self._attach()