stilt.execution.LocalExecutor#

class stilt.execution.LocalExecutor(n_workers: 'int' = 1) → 'None'[source]#

Run receptors on this machine, in one process or a process pool.

start() runs the receptors and returns when they are done, so Ctrl-C and SIGTERM reach the workers and stop them cleanly.

Parameters

n_workersint, default 1

Number of worker processes. 1 runs in this process.

Methods#

start(pending, *, project[, compute_root, ...])

Run pending receptors and return a handle once they are done.

Attributes#

dispatch

n_workers

Number of worker processes.