Changeset 93

Show
Ignore:
Timestamp:
10/06/07 16:20:26 (1 year ago)
Author:
edsuom
Message:

Minor fixes

Files:

Legend:

Unmodified
Added
Removed
Modified
Copied
Moved

  • projects/AsynCluster/trunk/asyncluster/master/jobs.py

    r88 r93  
    7272        def gotFinalStatus(success): 
    7373            if not success: 
    74                 self.disconnect() 
     74                self.client.disconnect() 
    7575            return success 
    7676 
    …… 
    8989        session is ended. 
    9090        """ 
    91         self.root = None 
    92         self.connector.disconnect() 
     91        def doneCanceling(null): 
     92            self.root = None 
     93            self.connector.disconnect() 
     94         
     95        jobID = getattr(self, 'jobID', None) 
     96        d = self.root.callRemote('cancelJob', jobID) 
     97        d.addCallback(doneCanceling) 
     98        return d 
    9399 
    94     def run(self, cmd, *args): 
     100    def run(self, cmd, *args, **kw): 
    95101        """ 
    96102        Does a job run on the next available node with any args supplied. 
    97103        """ 
    98104        if hasattr(self, 'jobID'): 
    99             return self.root.callRemote('runJob', self.jobID, cmd, *args) 
     105            return self.root.callRemote('runJob', self.jobID, cmd, *args, **kw) 
     106        raise Exception("No job registered!") 

  • projects/AsynQueue/trunk/asynqueue/jobs.py

    r92 r93  
    3030import base, workers 
    3131 
    32 VERBOSE = False 
     32VERBOSE = True 
    3333def log(msgProto, *args): 
    3434    if VERBOSE: