plumpy.process_listener module

class plumpy.process_listener.ProcessListener

Bases: Savable

_abc_impl = <_abc._abc_data object>

_auto_persist: Set[str] | None = {'_params'}

_params: Dict[str, Any]

init(**kwargs: Any) → None

load_instance_state(saved_state: MutableMapping[str, Any], load_context: LoadSaveContext | None) → None

on_output_emitted(process: Process, output_port: str, value: Any, dynamic: bool) → None

Called when the process has emitted an output value

Parameters:

• process – The process

• output_port – The output port that the value was outputted on

• value – The value that was outputted

• dynamic – True if the port is dynamic, False otherwise

on_process_created(process: Process) → None

Called when the process has been started

Parameters:

process – The process

on_process_excepted(process: Process, reason: str) → None

Called when the process has excepted

Parameters:

• process – The process

• reason – A string of the exception message

on_process_finished(process: Process, outputs: Any) → None

Called when the process has finished successfully

Parameters:

• process – The process

• outputs – The process outputs

on_process_killed(process: Process, msg: str) → None

Called when the process was killed

Parameters:

process – The process

on_process_paused(process: Process) → None

Called when the process is about to re-enter the RUNNING state

Parameters:

process – The process

on_process_played(process: Process) → None

Called when the process is about to re-enter the RUNNING state

Parameters:

process – The process

on_process_running(process: Process) → None

Called when the process is about to enter the RUNNING state

Parameters:

process – The process

on_process_waiting(process: Process) → None

Called when the process is about to enter the WAITING state

Parameters:

process – The process