Skip to content

Commit 6482846

Browse files
committed
Fixed import error
1 parent 45f07e4 commit 6482846

File tree

3 files changed

+6
-4
lines changed

3 files changed

+6
-4
lines changed

pyiceberg/expressions/__init__.py

Lines changed: 1 addition & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -35,16 +35,14 @@
3535

3636
from pydantic import Field
3737

38-
from pydantic import Field
39-
4038
from pyiceberg.expressions.literals import (
4139
AboveMax,
4240
BelowMin,
4341
Literal,
4442
literal,
4543
)
4644
from pyiceberg.schema import Accessor, Schema
47-
from pyiceberg.typedef import IcebergRootModel, L, StructProtocol
45+
from pyiceberg.typedef import IcebergBaseModel, IcebergRootModel, L, StructProtocol
4846
from pyiceberg.types import DoubleType, FloatType, NestedField
4947
from pyiceberg.utils.singleton import Singleton
5048

tests/expressions/test_expressions.py

Lines changed: 3 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -872,14 +872,17 @@ def test_not_in() -> None:
872872
assert not_in == eval(repr(not_in))
873873
assert not_in == pickle.loads(pickle.dumps(not_in))
874874

875+
875876
def test_serialize_in() -> None:
876877
pred = In(term="foo", literals=[1, 2, 3])
877878
assert pred.model_dump_json() == '{"type":"in","term":"foo","value":[1,2,3]}'
878879

880+
879881
def test_serialize_not_in() -> None:
880882
pred = NotIn(term="foo", literals=[1, 2, 3])
881883
assert pred.model_dump_json() == '{"type":"not-in","term":"foo","value":[1,2,3]}'
882884

885+
883886
def test_bound_equal_to(term: BoundReference[Any]) -> None:
884887
bound_equal_to = BoundEqualTo(term, literal("a"))
885888
assert str(bound_equal_to) == f"BoundEqualTo(term={str(term)}, literal=literal('a'))"

tests/integration/test_writes/test_writes.py

Lines changed: 2 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -866,7 +866,8 @@ def test_summaries_with_only_nulls(
866866
@pytest.mark.integration
867867
def test_duckdb_url_import(warehouse: Path, arrow_table_with_null: pa.Table) -> None:
868868
os.environ["TZ"] = "Etc/UTC"
869-
time.tzset()
869+
if hasattr(time, "tzset"):
870+
time.tzset()
870871
tz = pytz.timezone(os.environ["TZ"])
871872

872873
catalog = SqlCatalog("test_sql_catalog", uri="sqlite:///:memory:", warehouse=f"/{warehouse}")

0 commit comments

Comments
 (0)