Skip to content

Commit 089acdb

Browse files
committed
stop in python, closable only in scala
1 parent 7a5cb52 commit 089acdb

File tree

2 files changed

+3
-2
lines changed

2 files changed

+3
-2
lines changed

hail/python/hail/backend/py4j_backend.py

Lines changed: 2 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -187,7 +187,7 @@ def decode_bytearray(encoded):
187187
self._jbackend = jbackend
188188
self._jhc = jhc
189189

190-
self._backend_server = self._hail_package.backend.BackendServer.apply(self._jbackend)
190+
self._backend_server = self._hail_package.backend.BackendServer(self._jbackend)
191191
self._backend_server_port: int = self._backend_server.port()
192192
self._backend_server.start()
193193
self._requests_session = requests.Session()
@@ -307,6 +307,7 @@ def _to_java_blockmatrix_ir(self, ir):
307307

308308
def stop(self):
309309
self._backend_server.close()
310+
self._jbackend.close()
310311
self._jhc.stop()
311312
self._jhc = None
312313
self._registered_ir_function_names = set()

hail/python/hail/context.py

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -151,7 +151,7 @@ def default_reference(self, value):
151151

152152
def stop(self):
153153
assert self._backend
154-
self._backend.close()
154+
self._backend.stop()
155155
self._backend = None
156156
Env._hc = None
157157
Env._dummy_table = None

0 commit comments

Comments
 (0)