fix types around lint, tests with NOT_GIVEN migration

Author: tode-rl

pyproject.toml

@@ -98,6 +98,7 @@ build-backend = "hatchling.build"
 
 [dependency-groups]
 dev = [
+    "mypy>=1.18.2",
     "ruff>=0.12.7",
 ]
 

scripts/bootstrap

@@ -21,7 +21,4 @@ fi
 
 echo "==> Installing Python dependencies…"
 
-# experimental uv support makes installations significantly faster
-rye config --set-bool behavior.use-uv=true
-
-rye sync --all-features
+uv sync --all-extras --all-groups

scripts/format

@@ -5,4 +5,8 @@ set -e
 cd "$(dirname "$0")/.."
 
 echo "==> Running formatters"
-rye run format
+uv run ruff format
+uv run python scripts/utils/ruffen-docs.py README.md api.md
+uv run ruff check --fix .
+# run formatting again to fix any inconsistencies when imports are stripped
+uv run ruff format

scripts/lint

@@ -5,7 +5,7 @@ set -e
 cd "$(dirname "$0")/.."
 
 echo "==> Running lints"
-rye run lint
+uv run ruff check .
 
 echo "==> Making sure it imports"
-rye run python -c 'import runloop_api_client'
+uv run python -c 'import runloop_api_client'

scripts/test

@@ -63,7 +63,7 @@ if [ "${RUN_SMOKETESTS}" != "1" ]; then
   PYTEST_ARGS+=( -m "not smoketest" )
 fi
 
-rye run pytest "${PYTEST_ARGS[@]}" "$@"
+uv run pytest "${PYTEST_ARGS[@]}" "$@"
 
 echo "==> Running Pydantic v1 tests"
-rye run nox -s test-pydantic-v1 -- "${PYTEST_ARGS[@]}" "$@"
+uv run nox -s test-pydantic-v1 -- "${PYTEST_ARGS[@]}" "$@"

src/runloop_api_client/_models.py

@@ -179,7 +179,7 @@ def __str__(self) -> str:
     @classmethod
     @override
     def construct(  # pyright: ignore[reportIncompatibleMethodOverride]
-        __cls: Type[ModelT], # type: ignore
+        __cls: Type[ModelT],  # type: ignore
         _fields_set: set[str] | None = None,
         **values: object,
     ) -> ModelT:

src/runloop_api_client/resources/blueprints.py

@@ -12,7 +12,7 @@
     blueprint_preview_params,
     blueprint_list_public_params,
 )
-from .._types import Body, Omit, Query, Headers, NotGiven, SequenceNotStr, omit, not_given
+from .._types import NOT_GIVEN, Body, Omit, Query, Headers, NotGiven, SequenceNotStr, omit, not_given
 from .._utils import maybe_transform, async_maybe_transform
 from .._compat import cached_property
 from .._resource import SyncAPIResource, AsyncAPIResource

src/runloop_api_client/resources/devboxes/devboxes.py

@@ -37,7 +37,7 @@
     devbox_snapshot_disk_async_params,
     devbox_write_file_contents_params,
 )
-from ..._types import Body, Omit, Query, Headers, NotGiven, FileTypes, omit, not_given
+from ..._types import NOT_GIVEN, Body, Omit, Query, Headers, NotGiven, FileTypes, omit, not_given
 from ..._utils import is_given, extract_files, maybe_transform, deepcopy_minimal, async_maybe_transform
 from .browsers import (
     BrowsersResource,
@@ -805,7 +805,7 @@ def execute_and_await_completion(
         return the result within the initial request's timeout. If the execution is not yet
         complete, it switches to using wait_for_command to minimize latency while waiting.
         """
-        command_id = str(uuid7()) # type: ignore
+        command_id = str(uuid7())  # type: ignore
         execution = self.execute(
             devbox_id,
             command=command,
@@ -2249,7 +2249,7 @@ async def execute_and_await_completion(
         complete, it switches to using wait_for_command to minimize latency while waiting.
         """
 
-        command_id = str(uuid7()) # type: ignore
+        command_id = str(uuid7())  # type: ignore
         execution = await self.execute(
             devbox_id,
             command=command,

src/runloop_api_client/resources/devboxes/executions.py

@@ -363,10 +363,10 @@ def stream_stderr_updates(
             raise ValueError(f"Expected a non-empty value for `devbox_id` but received {devbox_id!r}")
         if not execution_id:
             raise ValueError(f"Expected a non-empty value for `execution_id` but received {execution_id!r}")
-        
-        default_headers: Headers = {'Accept': 'text/event-stream'}
+
+        default_headers: Headers = {"Accept": "text/event-stream"}
         merged_headers = default_headers if extra_headers is None else {**default_headers, **extra_headers}
-        
+
         if merged_headers and merged_headers.get(RAW_RESPONSE_HEADER):
             return self._get(
                 f"/v1/devboxes/{devbox_id}/executions/{execution_id}/stream_stderr_updates",
@@ -447,10 +447,10 @@ def stream_stdout_updates(
             raise ValueError(f"Expected a non-empty value for `devbox_id` but received {devbox_id!r}")
         if not execution_id:
             raise ValueError(f"Expected a non-empty value for `execution_id` but received {execution_id!r}")
-        
-        default_headers: Headers = {'Accept': 'text/event-stream'}
+
+        default_headers: Headers = {"Accept": "text/event-stream"}
         merged_headers = default_headers if extra_headers is None else {**default_headers, **extra_headers}
-        
+
         if merged_headers and merged_headers.get(RAW_RESPONSE_HEADER):
             return self._get(
                 f"/v1/devboxes/{devbox_id}/executions/{execution_id}/stream_stdout_updates",
@@ -816,10 +816,10 @@ async def stream_stderr_updates(
             raise ValueError(f"Expected a non-empty value for `devbox_id` but received {devbox_id!r}")
         if not execution_id:
             raise ValueError(f"Expected a non-empty value for `execution_id` but received {execution_id!r}")
-        
-        default_headers: Headers = {'Accept': 'text/event-stream'}
+
+        default_headers: Headers = {"Accept": "text/event-stream"}
         merged_headers = default_headers if extra_headers is None else {**default_headers, **extra_headers}
-        
+
         if merged_headers and merged_headers.get(RAW_RESPONSE_HEADER):
             return await self._get(
                 f"/v1/devboxes/{devbox_id}/executions/{execution_id}/stream_stderr_updates",
@@ -900,11 +900,10 @@ async def stream_stdout_updates(
             raise ValueError(f"Expected a non-empty value for `devbox_id` but received {devbox_id!r}")
         if not execution_id:
             raise ValueError(f"Expected a non-empty value for `execution_id` but received {execution_id!r}")
-        
-        default_headers: Headers = {'Accept': 'text/event-stream'}
+
+        default_headers: Headers = {"Accept": "text/event-stream"}
         merged_headers = default_headers if extra_headers is None else {**default_headers, **extra_headers}
 
-        
         # If caller requested a raw or streaming response wrapper, return the underlying stream as-is
         if merged_headers and merged_headers.get(RAW_RESPONSE_HEADER):
             return await self._get(

src/runloop_api_client/resources/scenarios/runs.py

@@ -4,7 +4,7 @@
 
 import httpx
 
-from ..._types import Body, Omit, Query, Headers, NotGiven, omit, not_given
+from ..._types import NOT_GIVEN, Body, Omit, Query, Headers, NotGiven, omit, not_given
 from ..._utils import maybe_transform
 from ..._compat import cached_property
 from ..._resource import SyncAPIResource, AsyncAPIResource