Commit a7ccf0c5 authored by Fabian Wachsmann's avatar Fabian Wachsmann
Browse files

Debugged missing selfes

parent ce091911
...@@ -155,7 +155,7 @@ class Tzis(): ...@@ -155,7 +155,7 @@ class Tzis():
# In[7]: # In[7]:
def _sel_range_for_chunk_by_time(ds, starttimeindex, endtimeindex): def _sel_range_for_chunk_by_time(self, ds, starttimeindex, endtimeindex):
return ds.isel(time=slice(starttimeindex,endtimeindex)) return ds.isel(time=slice(starttimeindex,endtimeindex))
...@@ -179,7 +179,7 @@ class Tzis(): ...@@ -179,7 +179,7 @@ class Tzis():
def _sel_range_for_chunk(self, ds, startindex, endindex, chunkdim): def _sel_range_for_chunk(self, ds, startindex, endindex, chunkdim):
if chunkdim == "time" : if chunkdim == "time" :
return self._sel_range_for_chunk_by_time(ds, startindex, endindex) return self._sel_range_for_chunk_by_time(self, ds, startindex, endindex)
else: else:
raise ValueError('Other chunk dimensions than "time" are not supported yet.') raise ValueError('Other chunk dimensions than "time" are not supported yet.')
...@@ -252,7 +252,7 @@ class Tzis(): ...@@ -252,7 +252,7 @@ class Tzis():
return write_status return write_status
return 0 return 0
def write_directly(dset=None, store=None): def write_directly(self, dset=None, store=None):
dset.to_zarr(store=store, mode='w', consolidated=True) dset.to_zarr(store=store, mode='w', consolidated=True)
def write_with_validation_and_retries(self, ds, varname, store, chunkdim, target_mb, startchunk, validity_check, maxretries): def write_with_validation_and_retries(self, ds, varname, store, chunkdim, target_mb, startchunk, validity_check, maxretries):
......
Markdown is supported
0% or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment