element_51.job_exec

Run a job’s code, the same way in a thread and in a child process.

Functions

execute(function, inputs, stop, sink)

Build the node and run it, as steps or in one call.

Classes

CallbackSink(*, begin, update, advance)

A Sink made of three functions.

JobReport(stop, node_type, update)

The Report a work job calls; it raises Stopped after Stop.

Sink(*args, **kwargs)

Where a running job's progress goes.

StopFlag(*args, **kwargs)

A flag Stop sets; a thread's or a process's event fits.