From 38ef5ece0a8f23bb4439908ca61dd6797c896ff0 Mon Sep 17 00:00:00 2001 From: Florian Maas Date: Tue, 16 Jul 2024 19:11:01 +0200 Subject: [PATCH] remove stale code --- python/deltalake/_internal.pyi | 8 +------- python/deltalake/writer.py | 16 +++++----------- 2 files changed, 6 insertions(+), 18 deletions(-) diff --git a/python/deltalake/_internal.pyi b/python/deltalake/_internal.pyi index a9989fa26d..debe460065 100644 --- a/python/deltalake/_internal.pyi +++ b/python/deltalake/_internal.pyi @@ -1,10 +1,4 @@ -import sys -from typing import Any, Dict, List, Mapping, Optional, Tuple, Union - -if sys.version_info >= (3, 8): - from typing import Literal -else: - from typing_extensions import Literal +from typing import Any, Dict, List, Literal, Mapping, Optional, Tuple, Union import pyarrow import pyarrow.fs as fs diff --git a/python/deltalake/writer.py b/python/deltalake/writer.py index 1718b5764b..35e71e1b4c 100644 --- a/python/deltalake/writer.py +++ b/python/deltalake/writer.py @@ -1,5 +1,4 @@ import json -import sys import uuid from dataclasses import dataclass from datetime import date, datetime @@ -13,6 +12,7 @@ Iterable, Iterator, List, + Literal, Mapping, Optional, Protocol, @@ -22,21 +22,14 @@ ) from urllib.parse import unquote -from deltalake import Schema as DeltaSchema -from deltalake.fs import DeltaStorageHandler - -from ._util import encode_partition_value - -if sys.version_info >= (3, 8): - from typing import Literal -else: - from typing_extensions import Literal - import pyarrow as pa import pyarrow.dataset as ds import pyarrow.fs as pa_fs from pyarrow import RecordBatchReader +from deltalake import Schema as DeltaSchema +from deltalake.fs import DeltaStorageHandler + from ._internal import DeltaDataChecker as _DeltaDataChecker from ._internal import batch_distinct from ._internal import convert_to_deltalake as _convert_to_deltalake @@ -45,6 +38,7 @@ ) from ._internal import write_new_deltalake as write_deltalake_pyarrow from ._internal import write_to_deltalake as write_deltalake_rust +from ._util import encode_partition_value from .exceptions import DeltaProtocolError, TableNotFoundError from .schema import ( convert_pyarrow_dataset,