Base#

class papercast.base.BasePipelineComponent[source]#

Bases: abc.ABC

init_logger(log_level: int = 20)[source]#
class papercast.base.BaseProcessor[source]#

Bases: papercast.base.BasePipelineComponent, abc.ABC

from_kwargs(**kwargs)[source]#
input_types: Dict[str, Any] = {}#
output_types: Dict[str, Any] = {}#
abstract process(input: papercast.production.Production, *args, **kwargs) → papercast.production.Production[source]#
class papercast.base.BasePublisher[source]#

Bases: papercast.base.BasePipelineComponent, abc.ABC

from_kwargs(**kwargs)[source]#
input_types: Dict[str, Any] = {}#
abstract process(input: papercast.production.Production, *args, **kwargs) → None[source]#
class papercast.base.BaseSubscriber[source]#

Bases: papercast.base.BasePipelineComponent, abc.ABC

abstract async subscribe() → papercast.production.Production[source]#
exception papercast.base.ValidationError[source]#

Bases: Exception

papercast.base.validate_inputs(func)[source]#