Skip to content

Commit

Permalink
vine: dask arg worker_transfers (cooperative-computing-lab#3943)
Browse files Browse the repository at this point in the history
* vine: dask arg worker_transfers

* typo

* typo
  • Loading branch information
JinZhou5042 authored Oct 24, 2024
1 parent d1f32de commit 78e0276
Showing 1 changed file with 5 additions and 1 deletion.
Original file line number Diff line number Diff line change
Expand Up @@ -144,7 +144,11 @@ def get(self, dsk, keys, *,
self.environment = environment

self.extra_files = extra_files
self.worker_transfers = worker_transfers or lazy_transfers
# if one of both is False, then worker_transfers is False, otherwise True
if not worker_transfers or not lazy_transfers:
self.worker_transfers = False
else:
self.worker_transfers = True
self.env_vars = env_vars
self.low_memory_mode = low_memory_mode
self.checkpoint_fn = checkpoint_fn
Expand Down

0 comments on commit 78e0276

Please sign in to comment.