pysqa.executor.executor.Executor#
- class pysqa.executor.executor.Executor(cwd: str | None = None, queue_adapter=None, queue_adapter_kwargs: dict | None = None)[source]#
Bases:
Executor- __init__(cwd: str | None = None, queue_adapter=None, queue_adapter_kwargs: dict | None = None)[source]#
Methods
__init__([cwd, queue_adapter, ...])map(fn, *iterables[, timeout, chunksize])Returns an iterator equivalent to map(fn, iter).
shutdown([wait, cancel_futures])Clean-up the resources associated with the Executor.
submit(fn, *args, **kwargs)Submits a callable to be executed with the given arguments.
- map(fn, *iterables, timeout=None, chunksize=1)[source]#
Returns an iterator equivalent to map(fn, iter).
- Parameters:
fn – A callable that will take as many arguments as there are passed iterables.
timeout – The maximum number of seconds to wait. If None, then there is no limit on the wait time.
chunksize – The size of the chunks the iterable will be broken into before being passed to a child process. This argument is only used by ProcessPoolExecutor; it is ignored by ThreadPoolExecutor.
- Returns:
map(func, *iterables) but the calls may be evaluated out-of-order.
- Return type:
An iterator equivalent to
- Raises:
TimeoutError – If the entire result iterator could not be generated before the given timeout.
Exception – If fn(*args) raises for any values.
- shutdown(wait: bool = True, *, cancel_futures: bool = False)[source]#
Clean-up the resources associated with the Executor.
It is safe to call this method several times. Otherwise, no other methods can be called after this one.
- Parameters:
wait – If True then shutdown will not return until all running futures have finished executing and the resources used by the executor have been reclaimed.
cancel_futures – If True then shutdown will cancel all pending futures. Futures that are completed or running will not be cancelled.