Changeset 96

Show
Ignore:
Timestamp:
10/18/07 17:30:38 (1 year ago)
Author:
edsuom
Message:

Got new job-update feature tested OK

Files:

Legend:

Unmodified
Added
Removed
Modified
Copied
Moved

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

    r95 r96  
    3131 
    3232JOB_CODE = """ 
     33G = [] 
     34 
     35def setup(x): 
     36    G.append(x) 
     37    return G 
     38 
    3339def test(a, b, c=0): 
    3440    return a + 2*b + 3*c 
    …… 
    4854        result = self.root.remote_newJob(JOB_ID, JOB_CODE) 
    4955        self.failUnlessEqual(result[0], True) 
    50         self.failUnlessElementsEqual(result[1], ['test', 'bogusable']) 
     56        self.failUnlessElementsEqual(result[1], ['setup', 'test', 'bogusable']) 
    5157     
    5258    def test_newJob_bogus(self): 
    …… 
    190196 
    191197    def test_attachChild_withUpdate(self): 
    192         self.fail( 
    193             "Test that attached child gets updated before running any jobs") 
     198        self.mgr.jobs[JOB_ID] = (JOB_CODE, 0) 
     199        # This must run first, on attachment 
     200        d1 = self.mgr.update(JOB_ID, 'setup', 1) 
     201        # The actual attachment event chain 
     202        d2 = self._attach() 
     203        d2.addCallback(self.mgr.run, 'setup', 2) 
     204        d2.addCallback(self.failUnlessEqual, [1, 2]) 
     205        # Wait for both 
     206        return defer.DeferredList([d1, d2]) 
    194207 
    195208    def test_new(self): 
    …… 
    238251        yield defer.waitForDeferred(defer.DeferredList(dList)) 
    239252        self.failUnlessEqual(results, range(10)) 
    240  
    241     def test_update(self): 
    242         self.fail("Test updates before next job runs")