equal
deleted
inserted
replaced
1 from functools import partial |
1 from functools import partial |
2 |
2 |
3 from ..error import NoRoute, RejectRecipient |
3 from ..error import NoRoute, RejectRecipient |
4 |
4 |
5 from ..model.offer import getPossibleOffers |
5 from ..model.offer import getPossibleOffers |
6 from ..model.job import jobs |
6 from ..model.job import exJobs |
7 |
7 |
8 from .pool import taskPool |
8 from .pool import taskPool |
9 |
9 |
10 class Task: |
10 class Task: |
11 '''one single part of a job. |
11 '''one single part of a job. |
29 continue |
29 continue |
30 else: |
30 else: |
31 raise NoRoute() |
31 raise NoRoute() |
32 |
32 |
33 |
33 |
34 def createJob(recipients, msg, offers): |
34 def createJob(user,recipients, msg, offers, info=None): |
35 job = jobs.create(recipients, msg, offers) |
35 job = exJobs.create(user, recipients, msg, offers, info) |
36 for r in recipients: |
36 for r in recipients: |
37 task = Task(r,job) |
37 task = Task(r,job) |
38 job.addTask(task) |
38 job.addTask(task) |
39 task.start() |
39 task.start() |
40 |
40 |