from typing import Any, Callable, Dict, List, Optional, Set
import cloudpickle # type: ignore
from typing import Any, Callable, Dict, List, Optional, Set
import cloudpickle # type: ignore
from ansi import bg, fg, underline, reset
import argparse_utils
from ansi import bg, fg, underline, reset
import argparse_utils
def shutdown(self, wait=True) -> None:
logger.debug(f'Shutting down processpool executor {self.title}')
self._process_executor.shutdown(wait)
def shutdown(self, wait=True) -> None:
logger.debug(f'Shutting down processpool executor {self.title}')
self._process_executor.shutdown(wait)
self.policy.register_worker_pool(self.workers)
self.cv = threading.Condition()
self._helper_executor = fut.ThreadPoolExecutor(
self.policy.register_worker_pool(self.workers)
self.cv = threading.Condition()
self._helper_executor = fut.ThreadPoolExecutor(
# they will move the result_file to this machine and let
# the original pick them up and unpickle them.
# they will move the result_file to this machine and let
# the original pick them up and unpickle them.
self.total_bundles_submitted += 1
return self._helper_executor.submit(self.launch, bundle)
self.total_bundles_submitted += 1
return self._helper_executor.submit(self.launch, bundle)
def shutdown(self, wait=True) -> None:
self._helper_executor.shutdown(wait)
logging.debug(f'Shutting down RemoteExecutor {self.title}')
def shutdown(self, wait=True) -> None:
self._helper_executor.shutdown(wait)
logging.debug(f'Shutting down RemoteExecutor {self.title}')