Skip to content

Commit 1393ab0

Browse files
committed
[query] make local and remote tmp settable on backend
1 parent 39cb74a commit 1393ab0

File tree

3 files changed

+31
-2
lines changed

3 files changed

+31
-2
lines changed

hail/python/hail/backend/backend.py

Lines changed: 10 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -392,3 +392,13 @@ def get_flags(self, *flags) -> Mapping[str, str]:
392392
@abc.abstractmethod
393393
def requires_lowering(self):
394394
pass
395+
396+
@property
397+
@abc.abstractmethod
398+
def local_tmpdir(self) -> str:
399+
pass
400+
401+
@property
402+
@abc.abstractmethod
403+
def remote_tmpdir(self) -> str:
404+
pass

hail/python/hail/backend/py4j_backend.py

Lines changed: 20 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -196,8 +196,8 @@ def decode_bytearray(encoded):
196196
self._jhc = jhc
197197

198198
self._jbackend = self._hail_package.backend.api.Py4JBackendApi(jbackend)
199-
self._jbackend.pySetLocalTmp(tmpdir)
200-
self._jbackend.pySetRemoteTmp(remote_tmpdir)
199+
self.local_tmpdir = tmpdir
200+
self.remote_tmpdir = tmpdir
201201

202202
self._jhttp_server = self._jbackend.pyHttpServer()
203203
self._backend_server_port: int = self._jhttp_server.port()
@@ -326,3 +326,21 @@ def stop(self):
326326
self._jhc = None
327327
uninstall_exception_handler()
328328
super().stop()
329+
330+
@property
331+
def local_tmpdir(self) -> str:
332+
return self._local_tmpdir
333+
334+
@local_tmpdir.setter
335+
def local_tmpdir(self, tmpdir) -> str:
336+
self._local_tmpdir = tmpdir
337+
self._jbackend.pySetLocalTmp(tmpdir)
338+
339+
@property
340+
def remote_tmpdir(self) -> str:
341+
return self._remote_tmpdir
342+
343+
@remote_tmpdir.setter
344+
def remote_tmpdir(self, tmpdir) -> str:
345+
self._remote_tmpdir = tmpdir
346+
self._jbackend.pySetRemoteTmp(tmpdir)

hail/python/hail/backend/service_backend.py

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -239,6 +239,7 @@ def __init__(
239239
self._batch_was_submitted: bool = False
240240
self.disable_progress_bar = disable_progress_bar
241241
self.batch_attributes = batch_attributes
242+
self.local_tmpdir = tmp_dir()
242243
self.remote_tmpdir = remote_tmpdir
243244
self.flags: Dict[str, str] = {}
244245
self._registered_ir_function_names: Set[str] = set()

0 commit comments

Comments
 (0)