fix(python): normalize merge insert column lists

This commit is contained in:
Gatefixer
2026-08-06 07:51:07 +00:00
parent 7357d63e87
commit 13eb1f19f4
2 changed files with 27 additions and 2 deletions
+2 -2
View File
@@ -1346,7 +1346,7 @@ class Table(ABC):
2 3 y
3 4 z
""" # noqa: E501
on = [on] if isinstance(on, str) else list(iter(on))
on = [on] if isinstance(on, str) else list(on)
return LanceMergeInsertBuilder(self, on)
@@ -5236,7 +5236,7 @@ class AsyncTable:
2 3 y
3 4 z
""" # noqa: E501
on = [on] if isinstance(on, str) else list(iter(on))
on = [on] if isinstance(on, str) else list(on)
return LanceMergeInsertBuilder(self, on)
+25
View File
@@ -2265,6 +2265,31 @@ def test_update_types(mem_db: DBConnection):
assert actual == expected
def test_merge_insert_accepts_column_list(mem_db: DBConnection):
table = mem_db.create_table(
"my_table",
data=pa.table({"a": [1], "b": [2]}),
)
builder = table.merge_insert(["a", "b"])
assert builder._on == ["a", "b"]
@pytest.mark.asyncio
async def test_merge_insert_accepts_column_list_async(
mem_db_async: AsyncConnection,
):
table = await mem_db_async.create_table(
"my_table",
data=pa.table({"a": [1], "b": [2]}),
)
builder = table.merge_insert(["a", "b"])
assert builder._on == ["a", "b"]
def test_merge_insert(mem_db: DBConnection):
table = mem_db.create_table(
"my_table",