spreadflow_core.subprocess module

Components for multiprocessing.

class spreadflow_core.subprocess.SubprocessController(name, innames=None, outnames=None)

Bases: spreadflow_core.remote.ClientEndpointMixin

Subprocess controller component.

Parameters:

• ins (string[]) – A list of names for the input ports.
• outs (string[]) – A list of names for the output ports.

get_client_protocol_factory(scheduler, reactor)

ins

outs

class spreadflow_core.subprocess.SubprocessWorker(innames=None, outnames=None)

Bases: spreadflow_core.remote.ServerEndpointMixin

Subprocess worker component.

Parameters:

• ins (string[]) – A list of names for the input ports.
• outs (string[]) – A list of names for the output ports.

get_server_protocol_factory(scheduler, reactor)

ins

outs