Skip to content

Commit

Permalink
Allow passing in a list
Browse files Browse the repository at this point in the history
Signed-off-by: Vibhu Jawa <[email protected]>
  • Loading branch information
VibhuJawa committed Oct 8, 2024
1 parent 12e0051 commit a2bf28f
Showing 1 changed file with 7 additions and 4 deletions.
11 changes: 7 additions & 4 deletions dask_cuda/local_cuda_cluster.py
Original file line number Diff line number Diff line change
Expand Up @@ -289,9 +289,12 @@ def __init__(
self.rmm_managed_memory = rmm_managed_memory
self.rmm_async = rmm_async
self.rmm_release_threshold = rmm_release_threshold
if rmm_allocator_external_lib_list is not None:
rmm_allocator_external_lib_list = [s.strip() for s in
rmm_allocator_external_lib_list.split(',')]
if rmm_allocator_external_lib_list is not None and isinstance(
rmm_allocator_external_lib_list, str
):
rmm_allocator_external_lib_list = [
s.strip() for s in rmm_allocator_external_lib_list.split(",")
]
self.rmm_allocator_external_lib_list = rmm_allocator_external_lib_list

if rmm_pool_size is not None or rmm_managed_memory or rmm_async:
Expand Down Expand Up @@ -447,7 +450,7 @@ def new_worker_spec(self):
release_threshold=self.rmm_release_threshold,
log_directory=self.rmm_log_directory,
track_allocations=self.rmm_track_allocations,
external_lib_list=self.rmm_allocator_external_lib_list
external_lib_list=self.rmm_allocator_external_lib_list,
),
PreImport(self.pre_import),
CUDFSetup(self.enable_cudf_spill, self.cudf_spill_stats),
Expand Down

0 comments on commit a2bf28f

Please sign in to comment.