Skip to content

Commit 2d54535

Browse files
committed
fix: change result output for insert, update, delete
1 parent de2aeca commit 2d54535

2 files changed

Lines changed: 4 additions & 4 deletions

File tree

pyproject.toml

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -1,6 +1,6 @@
11
[project]
22
name = "query-farm-flight-server"
3-
version = "0.1.4"
3+
version = "0.1.5"
44
description = "A framework for building Arrow Flight servers for the DuckDB Airport extension with robust authentication, schema management, and data handling capabilities."
55
authors = [{ name = "Rusty Conover", email = "hello@query.farm" }]
66
dependencies = [

src/query_farm_flight_server/server.py

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -768,7 +768,7 @@ def do_exchange(
768768
writer=writer,
769769
return_chunks=return_chunks,
770770
)
771-
last_metadata = {"total_inserted": keys_inserted}
771+
last_metadata = {"total_changed": keys_inserted}
772772
elif airport_operation == ExchangeOperation.UPDATE:
773773
keys_updated = self.exchange_update(
774774
context=call_context,
@@ -777,7 +777,7 @@ def do_exchange(
777777
writer=writer,
778778
return_chunks=return_chunks,
779779
)
780-
last_metadata = {"total_updated": keys_updated}
780+
last_metadata = {"total_changed": keys_updated}
781781
elif airport_operation == ExchangeOperation.DELETE:
782782
keys_deleted = self.exchange_delete(
783783
context=call_context,
@@ -786,7 +786,7 @@ def do_exchange(
786786
writer=writer,
787787
return_chunks=return_chunks,
788788
)
789-
last_metadata = {"total_deleted": keys_deleted}
789+
last_metadata = {"total_changed": keys_deleted}
790790
elif airport_operation == ExchangeOperation.SCALAR_FUNCTION:
791791
self.exchange_scalar_function(
792792
context=call_context,

0 commit comments

Comments
 (0)