Source code for eventscore.core.exceptions

class EventsCoreError(Exception):
    message = "eventscore error occured."





class AlreadySpawnedError(EventsCoreError):
    message = "Not able to modify consumers after spawning workers."





class ClonesMismatchError(EventsCoreError):
    message = "Pipeline must have the same number of clones for all items."





class EmptyPipelineError(EventsCoreError):
    message = "Pipeline must have at least one item."





class UnrelatedConsumersError(EventsCoreError):
    message = "All consumers in pipeline must be related to the same event."





class EventNotSentError(EventsCoreError):
    message = "Could not send message to stream due to an unexpected error."





class EmptyStreamError(EventsCoreError):
    message = "Stream does not have unprocessed messages."





class TooManyDataError(EventsCoreError):
    message = "Unexpected number of data received for event."





class PathError(EventsCoreError):
    message = "Provided path does not exist."





class NotADirectoryError(EventsCoreError):
    message = "Provided root is not a directory."





class NotAPackageError(EventsCoreError):
    message = "Provided root is not a Python package."