Skip to content

Commit 7234b2c

Browse files
committed
fix: use typing.Union instead of |, which is Python 3.10+ only (closes #10)
1 parent 98f53ba commit 7234b2c

2 files changed

Lines changed: 11 additions & 10 deletions

File tree

wherobots/db/connection.py

Lines changed: 4 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -4,7 +4,7 @@
44
import threading
55
import uuid
66
from dataclasses import dataclass
7-
from typing import Callable, Any
7+
from typing import Any, Callable, Union
88

99
import cbor2
1010
import pyarrow
@@ -52,9 +52,9 @@ def __init__(
5252
self,
5353
ws: websockets.sync.client.ClientConnection,
5454
read_timeout: float = DEFAULT_READ_TIMEOUT_SECONDS,
55-
results_format: ResultsFormat | None = None,
56-
data_compression: DataCompression | None = None,
57-
geometry_representation: GeometryRepresentation | None = None,
55+
results_format: Union[ResultsFormat, None] = None,
56+
data_compression: Union[DataCompression, None] = None,
57+
geometry_representation: Union[GeometryRepresentation, None] = None,
5858
):
5959
self.__ws = ws
6060
self.__read_timeout = read_timeout

wherobots/db/driver.py

Lines changed: 7 additions & 6 deletions
Original file line numberDiff line numberDiff line change
@@ -10,6 +10,7 @@
1010
import requests
1111
import tenacity
1212
import threading
13+
from typing import Union
1314
import websockets.sync.client
1415

1516
from .constants import (
@@ -45,9 +46,9 @@ def connect(
4546
region: Region = None,
4647
wait_timeout: float = DEFAULT_SESSION_WAIT_TIMEOUT_SECONDS,
4748
read_timeout: float = DEFAULT_READ_TIMEOUT_SECONDS,
48-
results_format: ResultsFormat | None = None,
49-
data_compression: DataCompression | None = None,
50-
geometry_representation: GeometryRepresentation | None = None,
49+
results_format: Union[ResultsFormat, None] = None,
50+
data_compression: Union[DataCompression, None] = None,
51+
geometry_representation: Union[GeometryRepresentation, None] = None,
5152
) -> Connection:
5253
if not token and not api_key:
5354
raise ValueError("At least one of `token` or `api_key` is required")
@@ -145,9 +146,9 @@ def connect_direct(
145146
uri: str,
146147
headers: dict[str, str] = None,
147148
read_timeout: float = DEFAULT_READ_TIMEOUT_SECONDS,
148-
results_format: ResultsFormat | None = None,
149-
data_compression: DataCompression | None = None,
150-
geometry_representation: GeometryRepresentation | None = None,
149+
results_format: Union[ResultsFormat, None] = None,
150+
data_compression: Union[DataCompression, None] = None,
151+
geometry_representation: Union[GeometryRepresentation, None] = None,
151152
) -> Connection:
152153
q = queue.SimpleQueue()
153154
uri_with_protocol = append_protocol(uri, PROTOCOL_VERSION)

0 commit comments

Comments
 (0)