equal
deleted
inserted
replaced
14 a task is one message to one recipient |
14 a task is one message to one recipient |
15 ''' |
15 ''' |
16 def __init__(self, recipient, job): |
16 def __init__(self, recipient, job): |
17 self.recipient = recipient |
17 self.recipient = recipient |
18 self.job = job |
18 self.job = job |
|
19 self.status = None |
|
20 self.error = False |
|
21 |
|
22 def setStatus(self,status): |
|
23 self.status = status |
|
24 return status |
|
25 |
|
26 def setError(self,error): |
|
27 self.status = error |
|
28 self.error = True |
|
29 return error |
19 |
30 |
20 def start(self): |
31 def start(self): |
21 self.d = taskPool.run(self._run) |
32 self.d = taskPool.run(self._run) |
|
33 self.d.addCallback(self.setStatus) |
22 self.d.addCallback(partial(self.job.setStatus,self)) |
34 self.d.addCallback(partial(self.job.setStatus,self)) |
|
35 self.d.addErrback(self.setError) |
23 self.d.addErrback(partial(self.job.setError,self)) |
36 self.d.addErrback(partial(self.job.setError,self)) |
24 return self.d |
37 return self.d |
25 |
38 |
26 @inlineCallbacks |
39 @inlineCallbacks |
27 def _run(self): |
40 def _run(self): |