exopy.measurement.engines.process_engine.engine module

Engine executing the measurement in a different process.

class exopy.measurement.engines.process_engine.engine.ProcessEngine

Bases: exopy.measurement.engines.base_engine.BaseEngine

An engine executing the tasks it is sent in a different process.

perform(exec_infos)

Execute a given task.

Parameters

exec_infos (ExecutionInfos) – TaskInfos object describing the work to expected of the engine.

Returns

exec_infos – Input object whose values have been updated. This is simply a convenience.

Return type

ExecutionInfos

Notes

IOError in pipe are raised only if an operation is attempted from the process that closed the pipe, but never when trying to poll from a different process.

pause()

Ask the engine to pause the current task execution.

resume()

Ask the engine to resume the currently paused job.

stop(force=False)

Ask the engine to stop the current job.

This method should not wait for the job to stop save if a forced stop was requested.

Parameters

force (bool, optional) – Force the engine to stop the performing the task. This allow the engine to use any means necessary to stop, in this case only should the call to this method block.

shutdown(force=False)

Ask the engine to stop completely.

Parameters

force (bool, optional) – Force the engine to stop the performing the task. This allow the engine to use any means necessary to stop, in this case only should the call to this method block.