Exceptions

exception EventsCoreError

Bases: Exception

message = 'eventscore error occured.'

exception AlreadySpawnedError

Bases: EventsCoreError

message = 'Not able to modify consumers after spawning workers.'

exception ClonesMismatchError

Bases: EventsCoreError

message = 'Pipeline must have the same number of clones for all items.'

exception EmptyPipelineError

Bases: EventsCoreError

message = 'Pipeline must have at least one item.'

exception UnrelatedConsumersError

Bases: EventsCoreError

message = 'All consumers in pipeline must be related to the same event.'

exception EventNotSentError

Bases: EventsCoreError

message = 'Could not send message to stream due to an unexpected error.'

exception EmptyStreamError

Bases: EventsCoreError

message = 'Stream does not have unprocessed messages.'

exception TooManyDataError

Bases: EventsCoreError

message = 'Unexpected number of data received for event.'

exception PathError

Bases: EventsCoreError

message = 'Provided path does not exist.'

exception NotADirectoryError

Bases: EventsCoreError

message = 'Provided root is not a directory.'

exception NotAPackageError

Bases: EventsCoreError

message = 'Provided root is not a Python package.'