Skip to content

Commit a15b380

Browse files
chore(types): change optional parameter type from NotGiven to Omit
1 parent 87c1a17 commit a15b380

36 files changed

+1948
-1962
lines changed

src/orb/__init__.py

Lines changed: 3 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -3,7 +3,7 @@
33
import typing as _t
44

55
from . import types
6-
from ._types import NOT_GIVEN, Omit, NoneType, NotGiven, Transport, ProxiesTypes
6+
from ._types import NOT_GIVEN, Omit, NoneType, NotGiven, Transport, ProxiesTypes, omit, not_given
77
from ._utils import file_from_path
88
from ._client import Orb, Client, Stream, Timeout, AsyncOrb, Transport, AsyncClient, AsyncStream, RequestOptions
99
from ._models import BaseModel
@@ -50,7 +50,9 @@
5050
"ProxiesTypes",
5151
"NotGiven",
5252
"NOT_GIVEN",
53+
"not_given",
5354
"Omit",
55+
"omit",
5456
"OrbError",
5557
"APIError",
5658
"APIStatusError",

src/orb/_base_client.py

Lines changed: 9 additions & 9 deletions
Original file line numberDiff line numberDiff line change
@@ -42,7 +42,6 @@
4242
from ._qs import Querystring
4343
from ._files import to_httpx_files, async_to_httpx_files
4444
from ._types import (
45-
NOT_GIVEN,
4645
Body,
4746
Omit,
4847
Query,
@@ -57,6 +56,7 @@
5756
RequestOptions,
5857
HttpxRequestFiles,
5958
ModelBuilderProtocol,
59+
not_given,
6060
)
6161
from ._utils import is_dict, is_list, asyncify, is_given, lru_cache, is_mapping
6262
from ._compat import PYDANTIC_V1, model_copy, model_dump
@@ -146,9 +146,9 @@ def __init__(
146146
def __init__(
147147
self,
148148
*,
149-
url: URL | NotGiven = NOT_GIVEN,
150-
json: Body | NotGiven = NOT_GIVEN,
151-
params: Query | NotGiven = NOT_GIVEN,
149+
url: URL | NotGiven = not_given,
150+
json: Body | NotGiven = not_given,
151+
params: Query | NotGiven = not_given,
152152
) -> None:
153153
self.url = url
154154
self.json = json
@@ -596,7 +596,7 @@ def _maybe_override_cast_to(self, cast_to: type[ResponseT], options: FinalReques
596596
# we internally support defining a temporary header to override the
597597
# default `cast_to` type for use with `.with_raw_response` and `.with_streaming_response`
598598
# see _response.py for implementation details
599-
override_cast_to = headers.pop(OVERRIDE_CAST_TO_HEADER, NOT_GIVEN)
599+
override_cast_to = headers.pop(OVERRIDE_CAST_TO_HEADER, not_given)
600600
if is_given(override_cast_to):
601601
options.headers = headers
602602
return cast(Type[ResponseT], override_cast_to)
@@ -826,7 +826,7 @@ def __init__(
826826
version: str,
827827
base_url: str | URL,
828828
max_retries: int = DEFAULT_MAX_RETRIES,
829-
timeout: float | Timeout | None | NotGiven = NOT_GIVEN,
829+
timeout: float | Timeout | None | NotGiven = not_given,
830830
http_client: httpx.Client | None = None,
831831
custom_headers: Mapping[str, str] | None = None,
832832
custom_query: Mapping[str, object] | None = None,
@@ -1371,7 +1371,7 @@ def __init__(
13711371
base_url: str | URL,
13721372
_strict_response_validation: bool,
13731373
max_retries: int = DEFAULT_MAX_RETRIES,
1374-
timeout: float | Timeout | None | NotGiven = NOT_GIVEN,
1374+
timeout: float | Timeout | None | NotGiven = not_given,
13751375
http_client: httpx.AsyncClient | None = None,
13761376
custom_headers: Mapping[str, str] | None = None,
13771377
custom_query: Mapping[str, object] | None = None,
@@ -1847,8 +1847,8 @@ def make_request_options(
18471847
extra_query: Query | None = None,
18481848
extra_body: Body | None = None,
18491849
idempotency_key: str | None = None,
1850-
timeout: float | httpx.Timeout | None | NotGiven = NOT_GIVEN,
1851-
post_parser: PostParser | NotGiven = NOT_GIVEN,
1850+
timeout: float | httpx.Timeout | None | NotGiven = not_given,
1851+
post_parser: PostParser | NotGiven = not_given,
18521852
) -> RequestOptions:
18531853
"""Create a dict of type RequestOptions without keys of NotGiven values."""
18541854
options: RequestOptions = {}

src/orb/_client.py

Lines changed: 8 additions & 8 deletions
Original file line numberDiff line numberDiff line change
@@ -3,21 +3,21 @@
33
from __future__ import annotations
44

55
import os
6-
from typing import TYPE_CHECKING, Any, Union, Mapping
6+
from typing import TYPE_CHECKING, Any, Mapping
77
from typing_extensions import Self, override
88

99
import httpx
1010

1111
from . import _exceptions
1212
from ._qs import Querystring
1313
from ._types import (
14-
NOT_GIVEN,
1514
Omit,
1615
Timeout,
1716
NotGiven,
1817
Transport,
1918
ProxiesTypes,
2019
RequestOptions,
20+
not_given,
2121
)
2222
from ._utils import (
2323
is_given,
@@ -88,7 +88,7 @@ def __init__(
8888
api_key: str | None = None,
8989
webhook_secret: str | None = None,
9090
base_url: str | httpx.URL | None = None,
91-
timeout: Union[float, Timeout, None, NotGiven] = NOT_GIVEN,
91+
timeout: float | Timeout | None | NotGiven = not_given,
9292
max_retries: int = DEFAULT_MAX_RETRIES,
9393
default_headers: Mapping[str, str] | None = None,
9494
default_query: Mapping[str, object] | None = None,
@@ -278,9 +278,9 @@ def copy(
278278
api_key: str | None = None,
279279
webhook_secret: str | None = None,
280280
base_url: str | httpx.URL | None = None,
281-
timeout: float | Timeout | None | NotGiven = NOT_GIVEN,
281+
timeout: float | Timeout | None | NotGiven = not_given,
282282
http_client: httpx.Client | None = None,
283-
max_retries: int | NotGiven = NOT_GIVEN,
283+
max_retries: int | NotGiven = not_given,
284284
default_headers: Mapping[str, str] | None = None,
285285
set_default_headers: Mapping[str, str] | None = None,
286286
default_query: Mapping[str, object] | None = None,
@@ -418,7 +418,7 @@ def __init__(
418418
api_key: str | None = None,
419419
webhook_secret: str | None = None,
420420
base_url: str | httpx.URL | None = None,
421-
timeout: Union[float, Timeout, None, NotGiven] = NOT_GIVEN,
421+
timeout: float | Timeout | None | NotGiven = not_given,
422422
max_retries: int = DEFAULT_MAX_RETRIES,
423423
default_headers: Mapping[str, str] | None = None,
424424
default_query: Mapping[str, object] | None = None,
@@ -608,9 +608,9 @@ def copy(
608608
api_key: str | None = None,
609609
webhook_secret: str | None = None,
610610
base_url: str | httpx.URL | None = None,
611-
timeout: float | Timeout | None | NotGiven = NOT_GIVEN,
611+
timeout: float | Timeout | None | NotGiven = not_given,
612612
http_client: httpx.AsyncClient | None = None,
613-
max_retries: int | NotGiven = NOT_GIVEN,
613+
max_retries: int | NotGiven = not_given,
614614
default_headers: Mapping[str, str] | None = None,
615615
set_default_headers: Mapping[str, str] | None = None,
616616
default_query: Mapping[str, object] | None = None,

src/orb/_qs.py

Lines changed: 7 additions & 7 deletions
Original file line numberDiff line numberDiff line change
@@ -4,7 +4,7 @@
44
from urllib.parse import parse_qs, urlencode
55
from typing_extensions import Literal, get_args
66

7-
from ._types import NOT_GIVEN, NotGiven, NotGivenOr
7+
from ._types import NotGiven, not_given
88
from ._utils import flatten
99

1010
_T = TypeVar("_T")
@@ -41,8 +41,8 @@ def stringify(
4141
self,
4242
params: Params,
4343
*,
44-
array_format: NotGivenOr[ArrayFormat] = NOT_GIVEN,
45-
nested_format: NotGivenOr[NestedFormat] = NOT_GIVEN,
44+
array_format: ArrayFormat | NotGiven = not_given,
45+
nested_format: NestedFormat | NotGiven = not_given,
4646
) -> str:
4747
return urlencode(
4848
self.stringify_items(
@@ -56,8 +56,8 @@ def stringify_items(
5656
self,
5757
params: Params,
5858
*,
59-
array_format: NotGivenOr[ArrayFormat] = NOT_GIVEN,
60-
nested_format: NotGivenOr[NestedFormat] = NOT_GIVEN,
59+
array_format: ArrayFormat | NotGiven = not_given,
60+
nested_format: NestedFormat | NotGiven = not_given,
6161
) -> list[tuple[str, str]]:
6262
opts = Options(
6363
qs=self,
@@ -143,8 +143,8 @@ def __init__(
143143
self,
144144
qs: Querystring = _qs,
145145
*,
146-
array_format: NotGivenOr[ArrayFormat] = NOT_GIVEN,
147-
nested_format: NotGivenOr[NestedFormat] = NOT_GIVEN,
146+
array_format: ArrayFormat | NotGiven = not_given,
147+
nested_format: NestedFormat | NotGiven = not_given,
148148
) -> None:
149149
self.array_format = qs.array_format if isinstance(array_format, NotGiven) else array_format
150150
self.nested_format = qs.nested_format if isinstance(nested_format, NotGiven) else nested_format

src/orb/_types.py

Lines changed: 18 additions & 11 deletions
Original file line numberDiff line numberDiff line change
@@ -118,18 +118,21 @@ class RequestOptions(TypedDict, total=False):
118118
# Sentinel class used until PEP 0661 is accepted
119119
class NotGiven:
120120
"""
121-
A sentinel singleton class used to distinguish omitted keyword arguments
122-
from those passed in with the value None (which may have different behavior).
121+
For parameters with a meaningful None value, we need to distinguish between
122+
the user explicitly passing None, and the user not passing the parameter at
123+
all.
124+
125+
User code shouldn't need to use not_given directly.
123126
124127
For example:
125128
126129
```py
127-
def get(timeout: Union[int, NotGiven, None] = NotGiven()) -> Response: ...
130+
def create(timeout: Timeout | None | NotGiven = not_given): ...
128131
129132
130-
get(timeout=1) # 1s timeout
131-
get(timeout=None) # No timeout
132-
get() # Default timeout behavior, which may not be statically known at the method definition.
133+
create(timeout=1) # 1s timeout
134+
create(timeout=None) # No timeout
135+
create() # Default timeout behavior
133136
```
134137
"""
135138

@@ -141,13 +144,14 @@ def __repr__(self) -> str:
141144
return "NOT_GIVEN"
142145

143146

144-
NotGivenOr = Union[_T, NotGiven]
147+
not_given = NotGiven()
148+
# for backwards compatibility:
145149
NOT_GIVEN = NotGiven()
146150

147151

148152
class Omit:
149-
"""In certain situations you need to be able to represent a case where a default value has
150-
to be explicitly removed and `None` is not an appropriate substitute, for example:
153+
"""
154+
To explicitly omit something from being sent in a request, use `omit`.
151155
152156
```py
153157
# as the default `Content-Type` header is `application/json` that will be sent
@@ -157,15 +161,18 @@ class Omit:
157161
# to look something like: 'multipart/form-data; boundary=0d8382fcf5f8c3be01ca2e11002d2983'
158162
client.post(..., headers={"Content-Type": "multipart/form-data"})
159163
160-
# instead you can remove the default `application/json` header by passing Omit
161-
client.post(..., headers={"Content-Type": Omit()})
164+
# instead you can remove the default `application/json` header by passing omit
165+
client.post(..., headers={"Content-Type": omit})
162166
```
163167
"""
164168

165169
def __bool__(self) -> Literal[False]:
166170
return False
167171

168172

173+
omit = Omit()
174+
175+
169176
@runtime_checkable
170177
class ModelBuilderProtocol(Protocol):
171178
@classmethod

src/orb/_utils/_transform.py

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -268,7 +268,7 @@ def _transform_typeddict(
268268
annotations = get_type_hints(expected_type, include_extras=True)
269269
for key, value in data.items():
270270
if not is_given(value):
271-
# we don't need to include `NotGiven` values here as they'll
271+
# we don't need to include omitted values here as they'll
272272
# be stripped out before the request is sent anyway
273273
continue
274274

@@ -434,7 +434,7 @@ async def _async_transform_typeddict(
434434
annotations = get_type_hints(expected_type, include_extras=True)
435435
for key, value in data.items():
436436
if not is_given(value):
437-
# we don't need to include `NotGiven` values here as they'll
437+
# we don't need to include omitted values here as they'll
438438
# be stripped out before the request is sent anyway
439439
continue
440440

src/orb/_utils/_utils.py

Lines changed: 4 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -21,7 +21,7 @@
2121

2222
import sniffio
2323

24-
from .._types import NotGiven, FileTypes, NotGivenOr, HeadersLike
24+
from .._types import Omit, NotGiven, FileTypes, HeadersLike
2525

2626
_T = TypeVar("_T")
2727
_TupleT = TypeVar("_TupleT", bound=Tuple[object, ...])
@@ -63,7 +63,7 @@ def _extract_items(
6363
try:
6464
key = path[index]
6565
except IndexError:
66-
if isinstance(obj, NotGiven):
66+
if not is_given(obj):
6767
# no value was provided - we can safely ignore
6868
return []
6969

@@ -126,8 +126,8 @@ def _extract_items(
126126
return []
127127

128128

129-
def is_given(obj: NotGivenOr[_T]) -> TypeGuard[_T]:
130-
return not isinstance(obj, NotGiven)
129+
def is_given(obj: _T | NotGiven | Omit) -> TypeGuard[_T]:
130+
return not isinstance(obj, NotGiven) and not isinstance(obj, Omit)
131131

132132

133133
# Type safe methods for narrowing types with TypeVars.

0 commit comments

Comments
 (0)