Skip to content

Commit 2adf2b0

Browse files
committed
Sanitize table only for numpy backend
1 parent 0253f6e commit 2adf2b0

File tree

2 files changed

+2
-3
lines changed

2 files changed

+2
-3
lines changed

changelog.md

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -21,6 +21,6 @@
2121
* Improve progress bar by showing the description of the currently running task.
2222
* Allow passing the optional graph filter also as type `str` to `gds.graph.list()` instead of only `Graph`.
2323
* Listen and to SIGINT and SIGTERM and interrupt projection and write-backs based on GDS Session. Note this only works if the query runs in the main thread.
24-
24+
* Use arrow-based DataFrame backend for arrow-based operations and pandas>2.0
2525

2626
## Other changes

graphdatascience/query_runner/gds_arrow_client.py

Lines changed: 1 addition & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -676,11 +676,10 @@ def _do_get(
676676
message=r"Passing a BlockManager to DataFrame is deprecated",
677677
)
678678

679-
arrow_table = self._sanitize_arrow_table(arrow_table)
680-
681679
if ServerVersion.from_string(pandas.__version__) >= ServerVersion(2, 0, 0):
682680
return arrow_table.to_pandas(types_mapper=pandas.ArrowDtype) # type: ignore
683681
else:
682+
arrow_table = self._sanitize_arrow_table(arrow_table)
684683
return arrow_table.to_pandas() # type: ignore
685684

686685
def __enter__(self) -> GdsArrowClient:

0 commit comments

Comments
 (0)