Df Multicomm

class dffml.df.multicomm.BaseCommChannelConfig[source]: Config structure for a communication channel. It MUST include a dataflow parameter.

class dffml.df.multicomm.BaseMultiComm(config: Optional[Type[dffml.base.BaseConfig]])[source]: Abstract Base Class for mutlicomms

class dffml.df.multicomm.BaseMultiCommContext(parent: dffml.df.multicomm.BaseMultiComm)[source]

Abstract Base Class for mutlicomm contexts

abstract async register(config: dffml.df.multicomm.BaseCommChannelConfig) → None[source]: Register a communication channel with the multicomm context.

abstract register_config() → dffml.df.multicomm.BaseCommChannelConfig[source]: Return the config object to be passed to the resigter method

async register_directory(directory: Union[pathlib.Path, str]) → None[source]: Register all configs found in a directory

exception dffml.df.multicomm.MultiCommInAtomicMode[source]: Raised when registration is locked.

exception dffml.df.multicomm.NoConfigsForMultiComm[source]: Raised when no configs are found for the loaded type of multicomm

exception dffml.df.multicomm.NoDataFlows[source]: Raised when no dataflows are found

exception dffml.df.multicomm.NoDataFlowsForConfig[source]: Raised when no dataflows are found for a channel config