Skip to content

Commit

Permalink
Set default timeout to None to disable Dask cluster restarting in sav…
Browse files Browse the repository at this point in the history
…e_stack() function. This workaround produces issues in Docker containers on Apple Silicon with recent 'distributed' library versions. In case it is still required apply argument 'timeout=300' to the function call.
  • Loading branch information
Alexey Pechnikov committed Feb 16, 2024
1 parent a62a47f commit a01d295
Showing 1 changed file with 1 addition and 1 deletion.
2 changes: 1 addition & 1 deletion pygmtsar/pygmtsar/IO.py
Original file line number Diff line number Diff line change
Expand Up @@ -652,7 +652,7 @@ def open_stack(self, name, stack=None):
# import gc; gc.collect()

# use save_mfdataset
def save_stack(self, data, name, caption='Saving 2D Stack', queue=None, timeout=300):
def save_stack(self, data, name, caption='Saving 2D Stack', queue=None, timeout=None):
import numpy as np
import xarray as xr
import dask
Expand Down

0 comments on commit a01d295

Please sign in to comment.