Source code for eventscore.core.exceptions


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






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






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






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






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






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






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






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






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






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






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