iro/controller/task.py
branchdevel
changeset 161 072ee139eb67
parent 143 0b265608b6ce
child 162 497d6b9b6914
equal deleted inserted replaced
160:f4e4f4ba25fb 161:072ee139eb67
    25 
    25 
    26     @inlineCallbacks
    26     @inlineCallbacks
    27     def _run(self):
    27     def _run(self):
    28         for offer in self.job.offers:
    28         for offer in self.job.offers:
    29             try:
    29             try:
    30                 ret = yield offers[offer].send(self.recipient,self.job.message)
    30                 ret = yield offers[offer](self.recipient,self.job.message)
    31                 returnValue(ret)
    31                 returnValue(ret)
    32             except RejectRecipient:
    32             except RejectRecipient:
    33                 continue
    33                 continue
    34         else:
    34         else:
    35             raise NoRoute()
    35             raise NoRoute()