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[BaseConfig]])[source]¶: Abstract Base Class for mutlicomms

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

Abstract Base Class for mutlicomm contexts

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

abstract register_config() → BaseCommChannelConfig[source]¶: Return the config object to be passed to the resigter method

async register_directory(directory: Union[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