|
4 | 4 | import dataclasses as _dataclasses |
5 | 5 | import re |
6 | 6 | from ipaddress import IPv4Address, IPv4Interface, IPv4Network, IPv6Address, IPv6Interface, IPv6Network |
7 | | -from typing import TYPE_CHECKING, Any, Union |
| 7 | +from typing import TYPE_CHECKING, Any |
8 | 8 |
|
9 | 9 | from pydantic_core import MultiHostUrl, PydanticCustomError, Url, core_schema |
10 | 10 | from typing_extensions import Annotated, TypeAlias |
@@ -124,10 +124,7 @@ def __hash__(self) -> int: |
124 | 124 | UrlConstraints(allowed_schemes=['redis', 'rediss'], default_host='localhost', default_port=6379, default_path='/0'), |
125 | 125 | ] |
126 | 126 | """A type that will accept any Redis DSN.""" |
127 | | -MongoDsn = Union[ |
128 | | - Annotated[MultiHostUrl, UrlConstraints(allowed_schemes=['mongodb'], default_port=27017)], |
129 | | - Annotated[MultiHostUrl, UrlConstraints(allowed_schemes=['mongodb+srv'])], |
130 | | -] |
| 127 | +MongoDsn = Annotated[MultiHostUrl, UrlConstraints(allowed_schemes=['mongodb', 'mongodb+srv'], default_port=27017)] |
131 | 128 | """A type that will accept any MongoDB DSN.""" |
132 | 129 | KafkaDsn = Annotated[Url, UrlConstraints(allowed_schemes=['kafka'], default_host='localhost', default_port=9092)] |
133 | 130 | """A type that will accept any Kafka DSN.""" |
|
0 commit comments