Skip to content

Commit

Permalink
Addresssing comments
Browse files Browse the repository at this point in the history
  • Loading branch information
mrchtr committed Mar 12, 2024
1 parent b00a615 commit 2d87d8c
Showing 1 changed file with 3 additions and 2 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -48,12 +48,13 @@ def __init__( # PLR0913

def setup(self) -> Client:
"""Setup LocalCudaCluster if gpu is available."""
dask.config.set({"dataframe.convert-string": False})
dask.config.set({"distributed.worker.daemon": False})

if self.device == "cuda":
cluster = LocalCUDACluster()
return Client(cluster)

dask.config.set({"dataframe.convert-string": False})
dask.config.set({"distributed.worker.daemon": False})
total_memory = (os.sysconf("SC_PAGE_SIZE") * os.sysconf("SC_PHYS_PAGES")) / (
1024**3
)
Expand Down

0 comments on commit 2d87d8c

Please sign in to comment.