Each reflect each boundary value outwards This mimics what the skimage.filters.gaussian_filter(... mode="nearest") does.

Normalize user provided arguments to blockwise or map_blocks We do a few things: 1. If they are string literals that might collide with blo

Optimize several dask collections at once. Returns equivalent dask collections that all share the same merged and optimized underlying graph.

Helper function for padding edges. Handles the cases where the only the values on the edge are needed.

* Parse Python dot notation code examples into a JS object. * * @param {string} raw - Raw Python dot notation code examples * @return {object} The

* Parse an environment variable declaration into a JS object. * * @param {string} raw - Raw environment variable declaration * @return {object} The

* Parse a YAML string into a JS object. * * @param {string} raw - Raw YAML input * @return {object} The parsed data

>>> from operator import add >>> partial_by_order(5, function=add, other=[(1, 10)]) 15

Copy a slice of an array around to its other side Useful to create periodic boundary conditions for overlap

Persist this dask collection into memory This turns a lazy Dask collection into a Dask collection with the same metadata, but now wit

Like ``get``, but remove the element if found See Also -------- dask.config.get dask.config.set

Flip negative indices around to positive ones >>> posify_index(10, 3) 3 >>> posify_index(10, -3) 7 >>> posify_index(10, [3, -3])

Approximate quantiles of Series Parameters ---------- q : list/array of floats, default 0.5 (50%) Iterable of num

Filter dataframe with complex expression Blocked version of pd.DataFrame.query Parameters ---------- expr: str

Reraise errors in this block to show metadata inference failure. Parameters ---------- funcname : str, optional If provided, will

Pseudorandomly split dataframe into different pieces row-wise Parameters ---------- frac : list List of floats th

variable-length, zig-zag encoding.

Reflect boundaries of array on the same side This is the converse of ``periodic``

Update configuration by re-reading yaml files and env variables This mutates the global dask.config.config, or the config parameter if p

Register dispatchable function

Metaclass that wraps exception type in RemoteException

Rename deprecated keys to new keys This helps migrate older configuration versions over time Returns ------- Applied deprecations

Reshape iterator to nested shape >>> reshapelist((2, 3), range(6)) [[0, 1, 2], [3, 4, 5]]

Rewrite an expression This leverages the ``._{kind}_down`` and ``._{kind}_up`` methods defined on each class Returns

Rewrite a stack of Blockwise expressions into a single blockwise expression Given a set of Blockwise layers, combine them into a single layer. T

Rewriting a filter to decompose OR clauses. If a predicate part is part of all OR clauses, we can move it to the front so that we can push it down

A version of sqrt that properly handles scalar masked arrays. To mimic ``np.ma`` reductions, we need to convert scalar masked arrays that hav

Sanitize the elements for indexing along one axis >>> sanitize_index([2, 3, 5]) array([2, 3, 5]) >>> sanitize_index([True, False, True, F

Serialize config data into a string. Typically used to pass config via the ``DASK_INTERNAL_INHERIT_CONFIG`` environment variable. Parameters

Direct Short-and-Fat QR Currently, this is a quick hack for non-tall-and-skinny matrices which are one chunk tall and (unless they are one ch

Splits dataframe into groups The group is determined by their final partition, and which stage we are in in the shuffle Parameters -

Solve the equation `a x = b` for `x`, assuming a is a triangular matrix. Parameters ---------- a : (M, M) array_like A trian

Find division locations and values in sorted list Examples -------- >>> L = ['A', 'B', 'C', 'D', 'E', 'F'] >>> sorted_division_locat

Split an array into a list of arrays (using slices) at the given breaks >>> split_at_breaks(np.arange(6), [3, 5]) [array([0, 1, 2]), array([3

Stack arrays along a new axis Given a sequence of dask arrays, form a new dask array by stacking them along a new dimension (axis=0 by d

Apply a function using argument tuples from the given bag. This is similar to ``itertools.starmap``, except it also accepts keyword a

Create lines of SVG text that show a grid Parameters ---------- x: numpy.ndarray y: numpy.ndarray offset: tuple translati

Return a view of the array with ``axis1`` and ``axis2`` interchanged. Refer to :func:`dask.array.swapaxes` for full documentation. S

Does this function take multiple arguments? >>> def f(x, y): pass >>> takes_multiple_arguments(f) True >>> def f(x): pass >>> ta

Label for a task on a dot graph. Examples -------- >>> from operator import add >>> task_label((add, 1, 2)) 'add' >>> task_la

Normalize a python object and merge all sub-graphs. - Replace ``Delayed`` with their keys - Convert literals to things the schedulers can han

Trim sides from each block This couples well with the overlap operation, which may leave excess data on each block See also --------

>>> unpack_singleton([[[[1]]]]) 1 >>> unpack_singleton(np.array(np.datetime64('2000-01-01'))) array('2000-01-01', dtype='datetime64[

Unzip a list of lists into ``nout`` outputs.

Transform a bag of tuples to ``n`` bags of their elements. Examples -------- >>> import dask.bag as db >>> b = db.fro

Validate the format of a dask key. See Also -------- iskey

Variance

Visualize several dask graphs simultaneously. Requires ``graphviz`` to be installed. All options that are not the dask graph(s) should b

Ensure that there is a warm thread pool. With num_workers=None on the default thread, this function warms up the default thread pool. With nu

Wrap up numpy function into dask.array

Return Blockwise-function arguments for a specific index