import uuid


class PipelineWaitTimeoutError(Exception):
    """Raised when waiting for a paused pipeline run to resume exceeds the deadline."""

    def __init__(self, run_id: uuid.UUID) -> None:
        self.run_id = run_id
        super().__init__(f"Timed out waiting for pipeline run {run_id} to resume")


class PipelineAlreadyRunningError(Exception):
    def __init__(self, run_id: uuid.UUID) -> None:
        self.run_id = run_id
        super().__init__(f"Pipeline already running (run_id={run_id})")


class PipelineRunNotFoundError(Exception):
    def __init__(self, run_id: uuid.UUID) -> None:
        self.run_id = run_id
        super().__init__(f"Pipeline run {run_id} not found")