diff options
Diffstat (limited to 'executors.py')
| -rw-r--r-- | executors.py | 4 |
1 files changed, 2 insertions, 2 deletions
diff --git a/executors.py b/executors.py index 0b4d80e..3cb0a91 100644 --- a/executors.py +++ b/executors.py @@ -476,6 +476,7 @@ class RemoteExecutor(BaseExecutor): policy: RemoteWorkerSelectionPolicy) -> None: super().__init__() self.workers = workers + self.policy = policy self.worker_count = 0 for worker in self.workers: self.worker_count += worker.count @@ -483,7 +484,6 @@ class RemoteExecutor(BaseExecutor): msg = f"We need somewhere to schedule work; count was {self.worker_count}" logger.critical(msg) raise Exception(msg) - self.policy = policy self.policy.register_worker_pool(self.workers) self.cv = threading.Condition() self._helper_executor = fut.ThreadPoolExecutor( @@ -493,7 +493,7 @@ class RemoteExecutor(BaseExecutor): self.status = RemoteExecutorStatus(self.worker_count) self.total_bundles_submitted = 0 logger.debug( - f'Creating remote processpool with {self.worker_count} remote endpoints.' + f'Creating remote processpool with {self.worker_count} remote worker threads.' ) def is_worker_available(self) -> bool: |