equal
deleted
inserted
replaced
1 from functools import partial |
1 from functools import partial |
2 |
2 |
3 from twisted.internet.defer import inlineCallbacks, returnValue |
3 from twisted.internet.defer import inlineCallbacks, returnValue |
4 |
4 |
5 from ..error import NoRoute, RejectRecipient |
5 from ..error import NoRouteForTask, RejectRecipient |
6 |
6 |
7 from ..model.offer import offers |
7 from ..model.offer import offers |
8 from ..model.job import exJobs |
8 from ..model.job import exJobs |
9 |
9 |
10 from .pool import taskPool |
10 from .pool import taskPool |
30 ret = yield offers[offer](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 NoRouteForTask() |
36 |
36 |
37 |
37 |
38 @inlineCallbacks |
38 @inlineCallbacks |
39 def createJob(user,recipients, msg, offers, info=None): |
39 def createJob(user,recipients, msg, offers, info=None): |
40 job = yield exJobs.create(user, recipients, msg, offers, info) |
40 job = yield exJobs.create(user, recipients, msg, offers, info) |