Pipelines

class ProcessPipeline(consumer_type=<class 'eventscore.core.consumers.Consumer'>, runner_type=<class 'eventscore.core.runners.ObserverRunner'>, logger=<RootLogger root (DEBUG)>)

Bases: IProcessPipeline

Parameters:

• consumer_type (type[IConsumer])

• runner_type (type[IRunner])

• logger (logging.Logger)