Skip to content

Commit f30afb9

Browse files
committed
Remove premature autoclose
lets rather assume the passed authenticated client can be always closed for now.
1 parent 0cccf98 commit f30afb9

File tree

2 files changed

+10
-9
lines changed

2 files changed

+10
-9
lines changed

graphdatascience/arrow_client/v1/gds_arrow_client.py

Lines changed: 8 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -24,11 +24,15 @@ class GdsArrowClient:
2424
def __init__(
2525
self,
2626
flight_client: AuthenticatedArrowClient,
27-
auto_close: bool = True,
2827
):
29-
"""Creates a new GdsArrowClient instance."""
28+
"""Creates a new GdsArrowClient instance.
29+
30+
Parameters
31+
----------
32+
flight_client : AuthenticatedArrowClient
33+
The authenticated flight client to use for communication with the GDS server. Ownership of the client is transferred to this GdsArrowClient.
34+
"""
3035
self._flight_client = flight_client
31-
self._auto_close = auto_close
3236
self._logger = logging.getLogger("gds_arrow_client")
3337

3438
def get_node_properties(
@@ -553,8 +557,7 @@ def __exit__(
553557
self.close()
554558

555559
def close(self) -> None:
556-
if self._auto_close:
557-
self._flight_client.close()
560+
self._flight_client.close()
558561

559562
@staticmethod
560563
def _sanitize_arrow_table(arrow_table: Table) -> Table:

graphdatascience/tests/unit/arrow_client/V1/test_gds_arrow_client.py

Lines changed: 2 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -127,8 +127,7 @@ def gds_client(flight_server: FlightServer) -> Generator[GdsArrowClient, None, N
127127
ArrowInfo(f"localhost:{flight_server.port}", True, True, ["v1"]),
128128
UsernamePasswordAuthentication("user", "password"),
129129
) as arrow_client:
130-
with GdsArrowClient(arrow_client, auto_close=False) as gds_client:
131-
yield gds_client
130+
yield GdsArrowClient(arrow_client)
132131

133132

134133
@pytest.fixture()
@@ -137,8 +136,7 @@ def flaky_gds_client(flaky_flight_server: FlakyFlightServer) -> Generator[GdsArr
137136
ArrowInfo(f"localhost:{flaky_flight_server.port}", True, True, ["v1"]),
138137
UsernamePasswordAuthentication("user", "password"),
139138
) as arrow_client:
140-
with GdsArrowClient(arrow_client, auto_close=False) as gds_client:
141-
yield gds_client
139+
yield GdsArrowClient(arrow_client)
142140

143141

144142
def test_create_graph_with_defaults(flight_server: FlightServer, gds_client: GdsArrowClient) -> None:

0 commit comments

Comments
 (0)