|
25 | 25 | ClassVar, |
26 | 26 | Protocol, |
27 | 27 | Required, |
| 28 | + Annotated, |
28 | 29 | ParamSpec, |
| 30 | + TypeAlias, |
29 | 31 | TypedDict, |
30 | 32 | TypeGuard, |
31 | 33 | final, |
|
79 | 81 | from ._constants import RAW_RESPONSE_HEADER |
80 | 82 |
|
81 | 83 | if TYPE_CHECKING: |
| 84 | + from pydantic import GetCoreSchemaHandler, ValidatorFunctionWrapHandler |
| 85 | + from pydantic_core import CoreSchema, core_schema |
82 | 86 | from pydantic_core.core_schema import ModelField, ModelSchema, LiteralSchema, ModelFieldsSchema |
| 87 | +else: |
| 88 | + try: |
| 89 | + from pydantic_core import CoreSchema, core_schema |
| 90 | + except ImportError: |
| 91 | + CoreSchema = None |
| 92 | + core_schema = None |
83 | 93 |
|
84 | 94 | __all__ = ["BaseModel", "GenericModel"] |
85 | 95 |
|
@@ -412,6 +422,76 @@ def model_dump_json( |
412 | 422 | ) |
413 | 423 |
|
414 | 424 |
|
| 425 | +class _EagerIterable(list[_T], Generic[_T]): |
| 426 | + """ |
| 427 | + Accepts any Iterable[T] input (including generators), consumes it |
| 428 | + eagerly, and validates all items upfront. |
| 429 | +
|
| 430 | + Validation preserves the original container type where possible |
| 431 | + (e.g. a set[T] stays a set[T]). Serialization (model_dump / JSON) |
| 432 | + always emits a list — round-tripping through model_dump() will not |
| 433 | + restore the original container type. |
| 434 | + """ |
| 435 | + |
| 436 | + @classmethod |
| 437 | + def __get_pydantic_core_schema__( |
| 438 | + cls, |
| 439 | + source_type: Any, |
| 440 | + handler: GetCoreSchemaHandler, |
| 441 | + ) -> CoreSchema: |
| 442 | + (item_type,) = get_args(source_type) or (Any,) |
| 443 | + item_schema: CoreSchema = handler.generate_schema(item_type) |
| 444 | + list_of_items_schema: CoreSchema = core_schema.list_schema(item_schema) |
| 445 | + |
| 446 | + return core_schema.no_info_wrap_validator_function( |
| 447 | + cls._validate, |
| 448 | + list_of_items_schema, |
| 449 | + serialization=core_schema.plain_serializer_function_ser_schema( |
| 450 | + cls._serialize, |
| 451 | + info_arg=False, |
| 452 | + ), |
| 453 | + ) |
| 454 | + |
| 455 | + @staticmethod |
| 456 | + def _validate(v: Iterable[_T], handler: "ValidatorFunctionWrapHandler") -> Any: |
| 457 | + original_type: type[Any] = type(v) |
| 458 | + |
| 459 | + # Normalize to list so list_schema can validate each item |
| 460 | + if isinstance(v, list): |
| 461 | + items: list[_T] = v |
| 462 | + else: |
| 463 | + try: |
| 464 | + items = list(v) |
| 465 | + except TypeError as e: |
| 466 | + raise TypeError("Value is not iterable") from e |
| 467 | + |
| 468 | + # Validate items against the inner schema |
| 469 | + validated: list[_T] = handler(items) |
| 470 | + |
| 471 | + # Reconstruct original container type |
| 472 | + if original_type is list: |
| 473 | + return validated |
| 474 | + # str(list) produces the list's repr, not a string built from items, |
| 475 | + # so skip reconstruction for str and its subclasses. |
| 476 | + if issubclass(original_type, str): |
| 477 | + return validated |
| 478 | + try: |
| 479 | + return original_type(validated) |
| 480 | + except (TypeError, ValueError): |
| 481 | + # If the type cannot be reconstructed, just return the validated list |
| 482 | + return validated |
| 483 | + |
| 484 | + @staticmethod |
| 485 | + def _serialize(v: Iterable[_T]) -> list[_T]: |
| 486 | + """Always serialize as a list so Pydantic's JSON encoder is happy.""" |
| 487 | + if isinstance(v, list): |
| 488 | + return v |
| 489 | + return list(v) |
| 490 | + |
| 491 | + |
| 492 | +EagerIterable: TypeAlias = Annotated[Iterable[_T], _EagerIterable] |
| 493 | + |
| 494 | + |
415 | 495 | def _construct_field(value: object, field: FieldInfo, key: str) -> object: |
416 | 496 | if value is None: |
417 | 497 | return field_get_default(field) |
|
![stainless-app[bot]](https://avatars.githubusercontent.com/in/378072?v=4&size=40){kind=avatar}
0 commit comments