Upgrading dask 0.17 to 0.18
Unknown0.17.5 → 0.18.2
UnknownUpgrade verdict
None of the 3 releases in this range publish notes, so breaking changes can't be ruled out.
In plain terms
- Some releases in this range publish no notes, so DepDelta can't rule out breaking changes.
- Their commits are listed with this comparison.
Must act Unknown for releases without notes
Releases without notes may still need changes. Check their commits before upgrading.
API changes
Generated by DepDelta from published Python source. Not mixed with prose notes.
- added:
export config - added:
export datasets
- removed:
export learn - added:
export PerformanceWarning - added:
export apply_gufunc - added:
export as_gufunc - added:
export assert_eq - added:
export average - added:
export from_zarr - added:
export gufunc - added:
export isneginf - added:
export isposinf - added:
export outer - added:
export pad - added:
export to_zarr
- removed:
function topk_postprocess(a, k, axis) - added:
function argtopk(a_plus_idx, k, axis, keepdims) - added:
function argtopk_aggregate(a_plus_idx, k, axis, keepdims) - added:
function slice_with_int_dask_array(x, idx, offset, x_size, axis) - added:
function slice_with_int_dask_array_aggregate(idx, chunk_outputs, x_chunks, axis) - added:
function topk_aggregate(a, k, axis, keepdims) - added:
variable take_along_axis
- changed:
function getem(arr, chunks, getitem=…, shape=…, out_name=…, lock=…, asarray=…) → function getem(arr, chunks, getitem=…, shape=…, out_name=…, lock=…, asarray=…, dtype=…) - changed:
function insert_to_ooc(arr, out, lock=…, region=…, return_stored=…, load_stored=…) → function insert_to_ooc(arr, out, lock=…, region=…, return_stored=…, load_stored=…, tok=…) - changed:
function normalize_chunks(chunks, shape=…) → function normalize_chunks(chunks, shape=…, limit=…, dtype=…, previous_chunks=…) - added:
class PerformanceWarning(Warning) - added:
function auto_chunks(chunks, shape, limit, dtype, previous_chunks=…) - added:
function from_zarr(url, component=…, storage_options=…, chunks=…, **kwargs) - added:
function round_to(c, s) - added:
function to_zarr(arr, url, component=…, storage_options=…, overwrite=…, compute=…, return_stored=…, **kwargs) - added:
method Array.to_zarr(*args, **kwargs) - added:
property Array.blocks - added:
property Array.chunksize
- changed:
function linspace(start, stop, num=…, chunks=…, dtype=…) → function linspace(start, stop, num=…, endpoint=…, retstep=…, chunks=…, dtype=…) - added:
function expand_pad_width(array, pad_width) - added:
function np_pad(array, pad_width, mode, extra_arg=…) - added:
function pad(array, pad_width, mode, **kwargs) - added:
function pad_edge(array, pad_width, mode, *args) - added:
function pad_reuse(array, pad_width, mode, *args) - added:
function pad_stats(array, pad_width, mode, *args) - added:
function pad_udf(array, pad_width, mode, **kwargs) - added:
function wrapped_pad_func(array, pad_func, iaxis_pad_width, iaxis, pad_func_kwargs)
- changed:
function expand_key(k, dims) → function expand_key(k, dims, name=…, axes=…)
- added:
class gufunc(object) - added:
constructor gufunc(pyfunc, **kwargs) - added:
function apply_gufunc(func, signature, *args, **kwargs) - added:
function as_gufunc(signature=…, **kwargs)
- removed:
function fit(model, x, y, get=…, **kwargs) - removed:
function predict(model, x)
- changed:
function qr(a, name=…) → function qr(a) - changed:
function svd(a, name=…) → function svd(a) - changed:
function svd_compressed(a, k, n_power_iter=…, seed=…, name=…) → function svd_compressed(a, k, n_power_iter=…, seed=…) - changed:
function tsqr(data, name=…, compute_svd=…) → function tsqr(data, compute_svd=…, _max_vchunk_size=…) - added:
function sfqr(data, name=…)
- added:
function take_along_axis(arr, indices, axis)
- removed:
function blockdims_dict_to_tuple(old, new) - removed:
function blockshape_dict_to_tuple(old_chunks, d) - removed:
variable DEFAULT_BLOCK_SIZE_LIMIT - removed:
variable DEFAULT_THRESHOLD
- changed:
function reduction(x, chunk, aggregate, axis=…, keepdims=…, dtype=…, split_every=…, combine=…, name=…, out=…) → function reduction(x, chunk, aggregate, axis=…, keepdims=…, dtype=…, split_every=…, combine=…, name=…, out=…, concatenate=…, output_size=…)
- added:
function average(a, axis=…, weights=…, returned=…) - added:
function outer(a, b)
- removed:
function slice_with_dask_array(x, index) - removed:
function take_sorted(outname, inname, blockdims, index, axis=…) - changed:
function take(outname, inname, blockdims, index, axis=…) → function take(outname, inname, chunks, index, axis=…) - added:
function slice_with_bool_dask_array(x, index) - added:
function slice_with_int_dask_array(x, index) - added:
function slice_with_int_dask_array_on_axis(x, idx, axis) - added:
function slicing_plan(chunks, index)
- added:
variable isneginf - added:
variable isposinf
- added:
export assert_eq
- changed:
function to_textfiles(b, path, name_function=…, compression=…, encoding=…, compute=…, get=…, storage_options=…) → function to_textfiles(b, path, name_function=…, compression=…, encoding=…, compute=…, storage_options=…, last_endline=…, **kwargs) - changed:
method Bag.groupby(grouper, method=…, npartitions=…, blocksize=…, max_branch=…) → method Bag.groupby(grouper, method=…, npartitions=…, blocksize=…, max_branch=…, shuffle=…) - changed:
method Bag.to_textfiles(path, name_function=…, compression=…, encoding=…, compute=…, get=…, storage_options=…) → method Bag.to_textfiles(path, name_function=…, compression=…, encoding=…, compute=…, storage_options=…, last_endline=…, **kwargs)
- added:
function assert_eq(a, b)
- added:
function get_mapper(fs, path)
- added:
field Callback.active
- added:
function makedirs(name, mode=…, exist_ok=…) - added:
variable FileExistsError
- added:
class set(object) - added:
constructor set(arg=…, config=…, lock=…, **kwargs) - added:
function collect(paths=…, env=…) - added:
function collect_env(env=…) - added:
function collect_yaml(paths=…) - added:
function ensure_file(source, destination=…, comment=…) - added:
function get(key, default=…, config=…) - added:
function merge(*dicts) - added:
function refresh(config=…, defaults=…, **kwargs) - added:
function rename(aliases, config=…) - added:
function update(old, new, priority=…) - added:
function update_defaults(new, config=…, defaults=…) - added:
variable PATH - added:
variable config - added:
variable config_lock - added:
variable defaults - added:
variable global_config - added:
variable no_default - added:
variable paths - added:
variable yaml
- removed:
class set_options(object) - removed:
constructor set_options(**kwargs) - added:
function set_options(*args, **kwargs)
- added:
export assert_eq - added:
export read_json - added:
export to_json
- added:
method Index.to_series()
- added:
export read_json - added:
export to_json
- changed:
function to_csv(df, filename, name_function=…, compression=…, compute=…, get=…, storage_options=…, **kwargs) → function to_csv(df, filename, name_function=…, compression=…, compute=…, get=…, scheduler=…, storage_options=…, **kwargs)
- changed:
function to_hdf(df, path, key, mode=…, append=…, get=…, name_function=…, compute=…, lock=…, dask_kwargs=…, **kwargs) → function to_hdf(df, path, key, mode=…, append=…, get=…, scheduler=…, name_function=…, compute=…, lock=…, dask_kwargs=…, **kwargs)
- added:
function read_json(url_path, orient=…, lines=…, storage_options=…, blocksize=…, sample=…, encoding=…, errors=…, compression=…, **kwargs) - added:
function read_json_chunk(chunk, encoding, errors, kwargs, meta=…) - added:
function read_json_file(f, orient, lines, kwargs) - added:
function to_json(df, url_path, orient=…, lines=…, storage_options=…, compute=…, encoding=…, errors=…, compression=…, **kwargs) - added:
function write_json_partition(df, openfile, kwargs)
- added:
field Rolling.agg - added:
method Rolling.aggregate(func, args=…, kwargs=…, **kwds)
- added:
function timeseries(start=…, end=…, freq=…, partition_freq=…, dtypes=…, seed=…)
- changed:
function ndependents(dependencies, dependents) → function ndependents(dependencies, dependents, total_dependencies)
- added:
function getsizeof(x)
- changed:
function get_scheduler_lock(get=…, collection=…) → function get_scheduler_lock(get=…, collection=…, scheduler=…) - added:
function factors(n) - added:
function has_keyword(func, keyword) - added:
function parse_bytes(s) - added:
variable byte_sizes