Upgrading dask 0.15 to 0.16
Unknown0.15.4 → 0.16.1
UnknownUpgrade verdict
None of the 2 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 compute - added:
export delayed - added:
export get - added:
export get_versions - added:
export is_dask_collection - added:
export istask - added:
export persist - added:
export set_options - added:
export visualize - added:
variable versions
- added:
export allclose - added:
export atleast_1d - added:
export atleast_2d - added:
export atleast_3d - added:
export block - added:
export flip - added:
export fliplr - added:
export flipud - added:
export float_power - added:
export frompyfunc - added:
export matmul - added:
export meshgrid - added:
export vdot
- added:
function view(x, dtype, order=…)
- changed:
function asanyarray(array) → function asanyarray(a) - changed:
function asarray(array) → function asarray(a) - changed:
function broadcast_to(x, shape) → function broadcast_to(x, shape, chunks=…) - changed:
function insert_to_ooc(out, arr, lock=…, region=…) → function insert_to_ooc(arr, out, lock=…, region=…, return_stored=…) - changed:
function store(sources, targets, lock=…, regions=…, compute=…, **kwargs) → function store(sources, targets, lock=…, regions=…, compute=…, return_stored=…, **kwargs) - added:
function block(arrays, allow_unknown_chunksizes=…) - added:
function load_chunk(x, index, lock, region) - added:
function retrieve_from_ooc(keys, dsk) - added:
function store_chunk(x, out, index, lock, region, return_stored)
- added:
function meshgrid(*xi, **kwargs)
- added:
variable GETNOREMOVE
- added:
variable choice
- changed:
function atleast_2d(x) → function atleast_2d(*arys) - changed:
function atleast_3d(x) → function atleast_3d(*arys) - changed:
function unique(x) → function unique(ar, return_index=…, return_inverse=…, return_counts=…) - added:
function allclose(arr1, arr2, rtol=…, atol=…, equal_nan=…) - added:
function atleast_1d(*arys) - added:
function flip(m, axis) - added:
function fliplr(m) - added:
function flipud(m) - added:
function matmul(a, b) - added:
function vdot(a, b)
- added:
class da_frompyfunc(object) - added:
constructor da_frompyfunc(func, nin, nout) - added:
function frompyfunc(func, nin, nout) - added:
variable float_power
- removed:
function get_async(*args, **kwargs) - removed:
function get_sync(*args, **kwargs)
- changed:
function safe_take(n, b) → function safe_take(n, b, warn=…) - changed:
method Bag.take(k, npartitions=…, compute=…) → method Bag.take(k, npartitions=…, compute=…, warn=…)
- removed:
class Base(object) - removed:
method Base.compute(**kwargs) - removed:
method Base.persist(**kwargs) - removed:
method Base.visualize(filename=…, format=…, optimize_graph=…, **kwargs) - added:
class DaskMethodsMixin(object) - added:
function is_dask_collection(x) - added:
function persist(*args, **kwargs) - added:
method DaskMethodsMixin.compute(**kwargs) - added:
method DaskMethodsMixin.persist(**kwargs) - added:
method DaskMethodsMixin.visualize(filename=…, format=…, optimize_graph=…, **kwargs)
- removed:
function normalize_OpenFileCreator(ofc) - added:
function get_pyarrow_filesystem(fs)
- added:
function infer_storage_options(urlpath, inherit_storage_options=…)
- changed:
constructor add_callbacks(*args) → constructor add_callbacks(*callbacks)
- added:
function get_named_args(func) - added:
variable string_types
- removed:
function defer_to_globals(name, falsey=…) - added:
class GlobalMethod(object) - added:
constructor GlobalMethod(default, key, falsey=…) - added:
function globalmethod(default=…, key=…, falsey=…) - added:
variable thread_state
- removed:
export rolling_apply - removed:
export rolling_count - removed:
export rolling_kurt - removed:
export rolling_max - removed:
export rolling_mean - removed:
export rolling_median - removed:
export rolling_min - removed:
export rolling_quantile - removed:
export rolling_skew - removed:
export rolling_std - removed:
export rolling_sum - removed:
export rolling_var - removed:
export rolling_window - added:
export rolling
- added:
function str_cat(self, *others, **kwargs) - added:
method StringAccessor.cat(others=…, sep=…, na_rep=…)
- removed:
function optimize(dsk, keys, **kwargs) - changed:
class Scalar(Base) → class Scalar(Base, OperatorMethodMixin) - added:
method Series.rename(index=…, inplace=…, sorted_index=…)
- changed:
function text_blocks_to_pandas(reader, block_lists, header, head, kwargs, collection=…, enforce=…) → function text_blocks_to_pandas(reader, block_lists, header, head, kwargs, collection=…, enforce=…, specified_dtypes=…)
- removed:
function normalize_ParquetFile(pf) - removed:
function normalize_PyArrowParquetDataset(ds) - removed:
variable default_encoding - removed:
variable fastparquet - removed:
variable pyarrow_parquet - changed:
function to_parquet(path, df, compression=…, write_index=…, has_nulls=…, fixed_text=…, object_encoding=…, storage_options=…, append=…, ignore_divisions=…, partition_on=…, compute=…, times=…) → function to_parquet(df, path, engine=…, compression=…, write_index=…, append=…, ignore_divisions=…, partition_on=…, storage_options=…, compute=…, **kwargs)
- changed:
function merge_indexed_dataframes(lhs, rhs, how=…, lsuffix=…, rsuffix=…, indicator=…) → function merge_indexed_dataframes(lhs, rhs, how=…, lsuffix=…, rsuffix=…, indicator=…, left_on=…, right_on=…, left_index=…, right_index=…)
- added:
variable fastparquet
- removed:
function rolling_window(arg, window, **kwargs) - removed:
function wrap_rolling(func, method_name) - removed:
variable rolling_apply - removed:
variable rolling_count - removed:
variable rolling_kurt - removed:
variable rolling_max - removed:
variable rolling_mean - removed:
variable rolling_median - removed:
variable rolling_min - removed:
variable rolling_quantile - removed:
variable rolling_skew - removed:
variable rolling_std - removed:
variable rolling_sum - removed:
variable rolling_var
- changed:
class Delayed(base.Base) → class Delayed(Base, OperatorMethodMixin)
- added:
function fix_bounds(start, end, min_span)
- removed:
function dont_optimize(dsk, keys, **kwargs)
- removed:
function infer_storage_options(urlpath, inherit_storage_options=…) - added:
class OperatorMethodMixin(object)