Errors

from vectorshift import (
    Pipeline,
    VectorshiftError,
    AuthenticationError,
    RateLimitError,
    PipelineRunFailedError,
)

try:
    result = Pipeline.fetch(name="my-pipeline").run({"q": "..."})
except AuthenticationError:
    ...  # missing or invalid key
except RateLimitError as e:
    ...  # back off; e.error_message contains the server hint
except PipelineRunFailedError as e:
    ...  # e.task_id, e.run_error
except VectorshiftError as e:
    ...  # fallback for any other SDK error

VectorshiftError                    # base for every SDK error
├── VectorshiftApiError             # HTTP error from the API (alias: ApiStatusError)
│   ├── BadRequestError             # 400
│   ├── AuthenticationError         # 401
│   ├── PermissionDeniedError       # 403
│   ├── NotFoundError               # 404
│   ├── UnprocessableEntityError    # 422
│   ├── RateLimitError              # 429
│   ├── InternalServerError         # 500+
│   ├── PipelineRunFailedError      # run completed with failed status
│   └── PollTimeoutError            # polling exceeded the timeout
├── ApiConnectionError              # network-level failure
│   └── ApiTimeoutError             # request timed out before reaching the API
├── SessionError                    # base for session errors
│   └── SessionDisconnectedError    # websocket dropped
└── (KnowledgeBase ingestion errors)

from vectorshift import Pipeline, NotFoundError, PermissionDeniedError

try:
    other = Pipeline.fetch(id="<id-from-another-org>")
except NotFoundError:
    ...  # most likely outcome — by design, 404 hides existence
except PermissionDeniedError:
    ...  # less common — key valid for the resource type but not this op

from vectorshift import ApiConnectionError, ApiTimeoutError

try:
    Pipeline.list()
except ApiTimeoutError:
    ...  # request never reached the API in time
except ApiConnectionError:
    ...  # network down, proxy issue, etc.

from vectorshift import PipelineRunFailedError, PollTimeoutError

try:
    result = pipeline.run({"q": "..."}, timeout=30)
except PipelineRunFailedError as e:
    print(f"run {e.task_id} failed: {e.run_error}")
except PollTimeoutError as e:
    print(f"run {e.task_id} did not complete within {e.timeout}s")

from vectorshift import SessionDisconnectedError

async with await agent.create_session() as session:
    await session.send("Hello")
    try:
        async for event in session.listen():
            ...
    except SessionDisconnectedError:
        ...  # reconnect or surface to the user