loky/reusable_executor.py
def _wait_job_completion(self):
        """Wait for the cache to be empty before resizing the pool."""
        # Issue a warning to the user about the bad effect of this usage.
        if len(self._pending_work_items) > 0:
            warnings.warn("Trying to resize an executor with running jobs: "
                          "waiting for jobs completion before resizing.",
                          UserWarning)
            mp.util.debug("Executor {} waiting for jobs completion before"
                          " resizing".format(self.executor_id))
        # Wait for the completion of the jobs
        while len(self._pending_work_items) > 0:
            time.sleep(1e-3)
def _wait_job_completion(self):
        # Issue a warning to the user about the bad effect of this usage.
        if len(self._pending_work_items) > 0:
            warnings.warn("Trying to resize an executor with running jobs: "
                          "waiting for jobs completion before resizing.",
                          UserWarning)
            mp.util.debug("Executor {} waiting for jobs completion before"
                          " resizing".format(self.executor_id))
        # Wait for the completion of the jobs
        while len(self._pending_work_items) > 0:
            time.sleep(1e-3)
def _wait_job_completion ( self ) : # Issue a warning to the user about the bad effect of this usage. if len ( self . _pending_work_items ) > 0 : warnings . warn ( "Trying to resize an executor with running jobs: " "waiting for jobs completion before resizing." , UserWarning ) mp . util . debug ( "Executor {} waiting for jobs completion before" " resizing" . format ( self . executor_id ) ) # Wait for the completion of the jobs while len ( self . _pending_work_items ) > 0 : time . sleep ( 1e-3 )
Wait for the cache to be empty before resizing the pool.
Wait for the cache to be empty before resizing the pool .