diff options
| author | Scott Gasch <[email protected]> | 2021-10-23 23:49:08 -0700 |
|---|---|---|
| committer | Scott Gasch <[email protected]> | 2021-10-23 23:49:08 -0700 |
| commit | d08bad64a6884f25d28a2c38c6cd1c87b4335188 (patch) | |
| tree | 9d0e4381b4da1a543acf907b769d1d4d88a3377e /executors.py | |
| parent | 351e77c767c9084aa486eedbdc9902c635b06261 (diff) | |
Adds site_config; adds Tuya lights. Bugfixes.
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: |