From d08bad64a6884f25d28a2c38c6cd1c87b4335188 Mon Sep 17 00:00:00 2001 From: Scott Gasch Date: Sat, 23 Oct 2021 23:49:08 -0700 Subject: Adds site_config; adds Tuya lights. Bugfixes. --- executors.py | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) (limited to 'executors.py') 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: -- cgit v1.3