plumpy.process_listener module

class plumpy.process_listener.ProcessListener[source]

Bases: object

_abc_impl = <_abc_data object>
on_output_emitted(process: Process, output_port: str, value: Any, dynamic: bool) → None[source]

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[source]

Called when the process has been started

Parameters

process – The process

on_process_excepted(process: Process, reason: str) → None[source]

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[source]

Called when the process has finished successfully

Parameters

  • process – The process

  • outputs – The process outputs

on_process_killed(process: Process, msg: str) → None[source]

Called when the process was killed

Parameters

process – The process

on_process_paused(process: Process) → None[source]

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

Parameters

process – The process

on_process_played(process: Process) → None[source]

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

Parameters

process – The process

on_process_running(process: Process) → None[source]

Called when the process is about to enter the RUNNING state

Parameters

process – The process

on_process_waiting(process: Process) → None[source]

Called when the process is about to enter the WAITING state

Parameters

process – The process

plumpy.process_comms module plumpy.process_spec module