|
@@ -71,12 +71,16 @@ class ProcessManager(BaseObject):
|
71
|
71
|
self.config = config
|
72
|
72
|
self._process_count = process_count
|
73
|
73
|
self.workers = []
|
74
|
|
- self.start_workers(process_count, job)
|
|
74
|
+ self.job = job
|
75
|
75
|
|
76
|
|
- def start_workers(self, worker_count: int, job: typing.Callable[..., typing.Any]) -> None:
|
|
76
|
+ @property
|
|
77
|
+ def process_count(self) -> int:
|
|
78
|
+ return self._process_count
|
|
79
|
+
|
|
80
|
+ def start_workers(self) -> None:
|
77
|
81
|
assert not self.workers
|
78
|
|
- for i in range(worker_count):
|
79
|
|
- self.workers.append(Worker(self.config, job))
|
|
82
|
+ for i in range(self._process_count):
|
|
83
|
+ self.workers.append(Worker(self.config, self.job))
|
80
|
84
|
|
81
|
85
|
def make_them_work(self, message: typing.Any) -> 'TODO':
|
82
|
86
|
responses = []
|