Skip to content

Commit

Permalink
again
Browse files Browse the repository at this point in the history
  • Loading branch information
deanm0000 committed Sep 6, 2024
1 parent fcdae15 commit 4f7904b
Showing 1 changed file with 4 additions and 5 deletions.
9 changes: 4 additions & 5 deletions py-polars/tests/unit/io/test_delta.py
Original file line number Diff line number Diff line change
Expand Up @@ -470,6 +470,10 @@ def test_write_delta_with_merge(tmp_path: Path) -> None:
"target_alias": "t",
},
)
assert isinstance(merger, TableMerger)
assert merger.predicate == "s.a = t.a"
assert merger.source_alias == "s"
assert merger.target_alias == "t"
except AttributeError:
import deltalake

Expand All @@ -478,11 +482,6 @@ def test_write_delta_with_merge(tmp_path: Path) -> None:
)
raise ValueError(msg) from None

assert isinstance(merger, TableMerger)
assert merger.predicate == "s.a = t.a"
assert merger.source_alias == "s"
assert merger.target_alias == "t"

merger.when_matched_delete(predicate="t.a > 2").execute()

result = pl.read_delta(str(tmp_path))
Expand Down

0 comments on commit 4f7904b

Please sign in to comment.