The dask_utils module.

This module implements functions related to dask.

New at 0.5

  1. Relocated to subfilter.utils.

Detailed Module Contents

The entire module is documented below.

Created on Mon Aug 2 11:33:51 2021

@author: paclk

subfilter.utils.dask_utils.re_chunk(f, chunks=None, xch='all', ych='all', zch='auto')

Wrapper to re-chunk dask array.

Parameters

  • f (dask array.) – Input field

  • chunks (dict, optional) – Chunk specification. The default is None.

  • xch (str or int, optional) – New chunking for x dimension. ‘all’ | ‘auto’ | int . The default is ‘all’.

  • ych (str or int, optional) – New chunking for y dimension. ‘all’ | ‘auto’ | int . The default is ‘all’.

  • zch (str or int, optional) – New chunking for z dimension. ‘all’ | ‘auto’ | int . The default is ‘all’.

Returns

f – re-chunked input field.

Return type

dask array.

subfilter.utils.dask_utils.guess_chunk(max_ch, dataset)