Upgrading dask 0.13 to 0.14
Unknown0.13.0 → 0.14.3
UnknownUpgrade verdict
None of the 4 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 asarray - added:
export indices - added:
export roll - added:
export tile
- added:
function arange(start, stop, step, length, dtype)
- removed:
constructor Array(dask, name, chunks, dtype, shape=…) - removed:
function reshape(array, shape) - changed:
function apply_infer_dtype(func, args, kwargs, funcname=…) → function apply_infer_dtype(func, args, kwargs, funcname, suggest_dtype=…) - changed:
function concatenate(seq, axis=…) → function concatenate(seq, axis=…, allow_unknown_chunksizes=…) - changed:
function from_array(x, chunks, name=…, lock=…, fancy=…) → function from_array(x, chunks, name=…, lock=…, fancy=…, getitem=…) - changed:
function getem(arr, chunks, shape=…, out_name=…, fancy=…, lock=…) → function getem(arr, chunks, getitem=…, shape=…, out_name=…, lock=…) - added:
function getarray_inline(a, b, lock=…) - added:
function reshapelist(shape, seq) - added:
function roll(array, shift, axis=…) - added:
function shapelist(a) - added:
function tile(A, reps) - added:
function transposelist(arrays, axes, extradims=…)
- added:
function indices(dimensions, dtype=…, chunks=…)
- added:
function fft_wrap(fft_func, kind=…, dtype=…) - added:
variable fft2 - added:
variable fftn - added:
variable ifft2 - added:
variable ifftn - added:
variable irfft2 - added:
variable irfftn - added:
variable rfft2 - added:
variable rfftn - added:
variable scipy
- removed:
function reshape(shape, seq)
- changed:
function optimize(dsk, keys, fuse_keys=…, fast_functions=…, inline_functions_fast_functions=…, **kwargs) → function optimize(dsk, keys, fuse_keys=…, fast_functions=…, inline_functions_fast_functions=…, rename_fused_keys=…, **kwargs) - added:
function hold_keys(dsk, dependencies)
- added:
function contract_tuple(chunks, factor) - added:
function expand_tuple(chunks, factor) - added:
function reshape(x, shape) - added:
function reshape_rechunk(inshape, outshape, inchunks)
- added:
function identity(x) - added:
function queue_get(q)
- removed:
export from_castra
- removed:
function from_castra(x, columns=…, index=…) - removed:
function load_castra_partition(castra, part, columns, index) - changed:
function empty_safe_aggregate(func, parts) → function empty_safe_aggregate(func, parts, is_last) - changed:
function empty_safe_apply(func, part) → function empty_safe_apply(func, part, is_last) - changed:
function optimize(dsk, keys, fuse_keys=…, **kwargs) → function optimize(dsk, keys, fuse_keys=…, rename_fused_keys=…, **kwargs) - changed:
function to_textfiles(b, path, name_function=…, compression=…, encoding=…, compute=…) → function to_textfiles(b, path, name_function=…, compression=…, encoding=…, compute=…, get=…) - changed:
method Bag.to_textfiles(path, name_function=…, compression=…, encoding=…, compute=…) → method Bag.to_textfiles(path, name_function=…, compression=…, encoding=…, compute=…, get=…) - added:
function merge_distinct(seqs) - added:
function split(seq, n) - added:
function to_dataframe(seq, columns, dtypes)
- added:
method Base.persist(**kwargs)
- changed:
function get_fs_paths_myopen(urlpath, compression, mode, encoding=…, num=…, name_function=…, **kwargs) → function get_fs_paths_myopen(urlpath, compression, mode, encoding=…, errors=…, num=…, name_function=…, **kwargs)
- changed:
method DaskS3FileSystem.glob(path, **kwargs) → method DaskS3FileSystem.glob(path) - changed:
method DaskS3FileSystem.open(path, mode=…, **kwargs) → method DaskS3FileSystem.open(path, mode=…)
- added:
function defer_to_globals(name, falsey=…)
- changed:
function flatten(seq) → function flatten(seq, container=…) - added:
class literal(object) - added:
constructor literal(data)
- removed:
export from_castra - added:
export read_sql_table - added:
export to_datetime
- removed:
class CategoricalAccessor(Accessor) - removed:
field CategoricalAccessor.ns - removed:
field DatetimeAccessor.ns - removed:
field StringAccessor.ns - removed:
method CategoricalAccessor.remove_unused_categories() - removed:
static method CategoricalAccessor.call(obj, attr, *args, **kwargs) - removed:
static method CategoricalAccessor.getattr(obj, attr) - removed:
static method DatetimeAccessor.call(obj, attr, *args) - removed:
static method DatetimeAccessor.getattr(obj, attr) - removed:
static method StringAccessor.call(obj, attr, *args, **kwargs) - removed:
static method StringAccessor.getattr(obj, attr) - added:
function maybe_wrap_pandas(obj, x)
- changed:
function categorize(df, columns=…, **kwargs) → function categorize(df, columns=…, index=…, split_every=…, **kwargs) - added:
class CategoricalAccessor(Accessor) - added:
method CategoricalAccessor.as_known(**kwargs) - added:
method CategoricalAccessor.as_unknown() - added:
method CategoricalAccessor.remove_unused_categories() - added:
property CategoricalAccessor.categories - added:
property CategoricalAccessor.codes - added:
property CategoricalAccessor.known - added:
property CategoricalAccessor.ordered
- added:
class DataFrame(_Frame) - added:
class Index(Series) - added:
class Scalar(Base) - added:
class Series(_Frame) - added:
constructor Scalar(dsk, name, meta, divisions=…) - added:
function apply_and_enforce(func, args, kwargs, meta) - added:
function apply_concat_apply(args, chunk=…, aggregate=…, combine=…, meta=…, token=…, chunk_kwargs=…, aggregate_kwargs=…, combine_kwargs=…, split_every=…, split_out=…, split_out_setup=…, split_out_setup_kwargs=…, **kwargs) - added:
function check_divisions(divisions) - added:
function cov_corr(df, min_periods=…, corr=…, scalar=…, split_every=…) - added:
function cov_corr_agg(data, cols, min_periods=…, corr=…, scalar=…) - added:
function cov_corr_chunk(df, corr=…) - added:
function cov_corr_combine(data, corr=…) - added:
function elemwise(op, *args, **kwargs) - added:
function finalize(results) - added:
function hash_shard(df, nparts, split_out_setup=…, split_out_setup_kwargs=…) - added:
function idxmaxmin_agg(x, fn=…, skipna=…, scalar=…) - added:
function idxmaxmin_chunk(x, fn=…, skipna=…) - added:
function idxmaxmin_combine(x, fn=…, skipna=…) - added:
function idxmaxmin_row(x, fn=…, skipna=…) - added:
function is_broadcastable(dfs, s) - added:
function map_partitions(func, *args, **kwargs) - added:
function maybe_shift_divisions(df, periods, freq) - added:
function new_dd_object(dsk, _name, meta, divisions) - added:
function optimize(dsk, keys, **kwargs) - added:
function pd_split(df, p, random_state=…) - added:
function quantile(df, q) - added:
function repartition(df, divisions=…, force=…) - added:
function repartition_divisions(a, b, name, out1, out2, force=…) - added:
function repartition_freq(df, freq=…) - added:
function repartition_npartitions(df, npartitions) - added:
function safe_head(df, n) - added:
function split_evenly(df, k) - added:
function split_out_on_cols(df, cols=…) - added:
function split_out_on_index(df) - added:
function to_datetime(arg, **kwargs) - added:
function to_delayed(df) - added:
method DataFrame.append(other) - added:
method DataFrame.apply(func, axis=…, args=…, meta=…, columns=…, **kwds) - added:
method DataFrame.applymap(func, meta=…) - added:
method DataFrame.assign(**kwargs) - added:
method DataFrame.categorize(columns=…, index=…, split_every=…, **kwargs) - added:
method DataFrame.clip(lower=…, upper=…, out=…) - added:
method DataFrame.clip_lower(threshold) - added:
method DataFrame.clip_upper(threshold) - added:
method DataFrame.corr(method=…, min_periods=…, split_every=…) - added:
method DataFrame.cov(min_periods=…, split_every=…) - added:
method DataFrame.drop(labels, axis=…, errors=…) - added:
method DataFrame.dropna(how=…, subset=…) - added:
method DataFrame.eval(expr, inplace=…, **kwargs) - added:
method DataFrame.get_dtype_counts() - added:
method DataFrame.get_ftype_counts() - added:
method DataFrame.groupby(by=…, **kwargs) - added:
method DataFrame.info(buf=…, verbose=…, memory_usage=…) - added:
method DataFrame.iterrows() - added:
method DataFrame.itertuples() - added:
method DataFrame.join(other, on=…, how=…, lsuffix=…, rsuffix=…, npartitions=…, shuffle=…) - added:
method DataFrame.memory_usage(index=…, deep=…) - added:
method DataFrame.merge(right, how=…, on=…, left_on=…, right_on=…, left_index=…, right_index=…, suffixes=…, indicator=…, npartitions=…, shuffle=…) - added:
method DataFrame.nlargest(n=…, columns=…, split_every=…) - added:
method DataFrame.nsmallest(n=…, columns=…, split_every=…) - added:
method DataFrame.pivot_table(index=…, columns=…, values=…, aggfunc=…) - added:
method DataFrame.query(expr, **kwargs) - added:
method DataFrame.rename(index=…, columns=…) - added:
method DataFrame.round(decimals=…) - added:
method DataFrame.select_dtypes(include=…, exclude=…) - added:
method DataFrame.set_index(other, drop=…, sorted=…, npartitions=…, divisions=…, **kwargs) - added:
method DataFrame.to_bag(index=…) - added:
method DataFrame.to_html(max_rows=…) - added:
method DataFrame.to_records(index=…) - added:
method DataFrame.to_string(max_rows=…) - added:
method DataFrame.to_timestamp(freq=…, how=…, axis=…) - added:
method Index.count(split_every=…) - added:
method Index.head(n=…, compute=…) - added:
method Index.max(split_every=…) - added:
method Index.min(split_every=…) - added:
method Index.shift(periods=…, freq=…) - added:
method Series.align(other, join=…, axis=…, fill_value=…) - added:
method Series.apply(func, convert_dtype=…, meta=…, name=…, args=…, **kwds) - added:
method Series.autocorr(lag=…, split_every=…) - added:
method Series.between(left, right, inclusive=…) - added:
method Series.cat() - added:
method Series.clip(lower=…, upper=…, out=…) - added:
method Series.clip_lower(threshold) - added:
method Series.clip_upper(threshold) - added:
method Series.combine(other, func, fill_value=…) - added:
method Series.combine_first(other) - added:
method Series.corr(other, method=…, min_periods=…, split_every=…) - added:
method Series.count(split_every=…) - added:
method Series.cov(other, min_periods=…, split_every=…) - added:
method Series.dropna() - added:
method Series.dt() - added:
method Series.groupby(by=…, **kwargs) - added:
method Series.isin(other) - added:
method Series.iteritems() - added:
method Series.map(arg, na_action=…, meta=…) - added:
method Series.memory_usage(index=…, deep=…) - added:
method Series.nlargest(n=…, split_every=…) - added:
method Series.nsmallest(n=…, split_every=…) - added:
method Series.nunique(split_every=…) - added:
method Series.quantile(q=…) - added:
method Series.round(decimals=…) - added:
method Series.str() - added:
method Series.to_bag(index=…) - added:
method Series.to_frame(name=…) - added:
method Series.to_string(max_rows=…) - added:
method Series.to_timestamp(freq=…, how=…, axis=…) - added:
method Series.unique(split_every=…, split_out=…) - added:
method Series.value_counts(split_every=…, split_out=…) - added:
property DataFrame.columns - added:
property DataFrame.dtypes - added:
property DataFrame.ndim - added:
property Index.index - added:
property Scalar.divisions - added:
property Scalar.dtype - added:
property Scalar.key - added:
property Series.dtype - added:
property Series.name - added:
property Series.nbytes - added:
property Series.ndim - added:
variable Cache - added:
variable aca - added:
variable no_default
- removed:
constructor DataFrameGroupBy(df, index=…, slice=…, **kwargs) - changed:
constructor SeriesGroupBy(df, index, slice=…, **kwargs) → constructor SeriesGroupBy(df, by=…, slice=…)
- changed:
function hash_array(vals) → function hash_array(vals, encoding=…, hash_key=…, categorize=…) - changed:
function hash_pandas_object(obj, index=…) → function hash_pandas_object(obj, index=…, encoding=…, hash_key=…, categorize=…) - added:
function hash_object_array(x, hash_key, encoding)
- removed:
export from_castra - removed:
export to_castra - added:
export read_sql_table
- changed:
function read_pandas(reader, urlpath, blocksize=…, collection=…, lineterminator=…, compression=…, sample=…, enforce=…, storage_options=…, **kwargs) → function read_pandas(reader, urlpath, blocksize=…, collection=…, lineterminator=…, compression=…, sample=…, enforce=…, assume_missing=…, storage_options=…, **kwargs)
- added:
function dataframe_from_ctable(x, slc, columns=…, categories=…, lock=…) - added:
function from_array(x, chunksize=…, columns=…) - added:
function from_bcolz(x, chunksize=…, categorize=…, index=…, lock=…, **kwargs) - added:
function from_dask_array(x, columns=…) - added:
function from_delayed(dfs, meta=…, divisions=…, prefix=…, metadata=…) - added:
function from_pandas(data, npartitions=…, chunksize=…, sort=…, name=…) - added:
function sorted_division_locations(seq, npartitions=…, chunksize=…) - added:
function to_bag(df, index=…) - added:
function to_records(df) - added:
variable lock
- changed:
function read_parquet(path, columns=…, filters=…, categories=…, index=…, storage_options=…) → function read_parquet(path, columns=…, filters=…, categories=…, index=…, storage_options=…, engine=…) - changed:
function to_parquet(path, df, compression=…, write_index=…, has_nulls=…, fixed_text=…, object_encoding=…, storage_options=…) → function to_parquet(path, df, compression=…, write_index=…, has_nulls=…, fixed_text=…, object_encoding=…, storage_options=…, append=…, ignore_divisions=…) - added:
function normalize_PyArrowParquetDataset(ds) - added:
variable pyarrow_parquet
- added:
function read_sql_table(table, uri, index_col, divisions=…, npartitions=…, limits=…, columns=…, bytes_per_chunk=…, **kwargs)
- changed:
function concat(dfs, axis=…, join=…) → function concat(dfs, axis=…, join=…, uniform=…)
- added:
function stack_partitions(dfs, divisions, join=…)
- removed:
function fuse_castra_index(dsk)
- changed:
constructor maybe_buffered_partd(buffer=…) → constructor maybe_buffered_partd(buffer=…, tempdir=…) - added:
function compute_divisions(df, **kwargs) - added:
function set_sorted_index(df, index, drop=…, divisions=…, **kwargs)
- removed:
function compute(*args, **kwargs) - removed:
property Delayed.dask - removed:
variable do - changed:
constructor Delayed(key, dasks, length=…) → constructor Delayed(key, dsk, length=…) - changed:
function delayed(obj, name=…, pure=…, nout=…) → function delayed(obj, name=…, pure=…, nout=…, traverse=…)
- added:
variable msg
- removed:
function dealias(dsk, keys=…, dependencies=…) - removed:
function dependency_dict(dsk) - removed:
function equivalent(term1, term2, subs=…) - removed:
function merge_sync(dsk1, dsk2) - removed:
function sync_keys(dsk1, dsk2) - changed:
function fuse(dsk, keys=…, dependencies=…) → function fuse(dsk, keys=…, dependencies=…, ave_width=…, max_width=…, max_height=…, max_depth_new_edges=…, rename_keys=…) - added:
function default_fused_keys_renamer(keys) - added:
function default_fused_linear_keys_renamer(keys) - added:
function dont_optimize(dsk, keys, **kwargs) - added:
function fuse_linear(dsk, keys=…, dependencies=…, rename_keys=…) - added:
function key_split(s) - added:
variable hex_pattern
- added:
class ShareDict(Mapping) - added:
constructor ShareDict() - added:
function merge(*dicts) - added:
method ShareDict.items() - added:
method ShareDict.update(arg) - added:
method ShareDict.update_with_key(arg, key=…)
- added:
function register_numpy() - added:
function register_pandas() - added:
function register_spmatrix() - added:
function sizeof_default(o) - added:
function sizeof_python_collection(seq) - added:
variable getsizeof - added:
variable sizeof
- removed:
function key_split(s) - removed:
variable hex_pattern - changed:
constructor Dispatch() → constructor Dispatch(name=…) - added:
function effective_get(get=…, collection=…) - added:
function ensure_dict(d) - added:
function get_scheduler_lock(get=…, collection=…) - added:
function homogeneous_deepmap(func, seq) - added:
function ndeepmap(n, func, seq) - added:
function package_of(typ)
- added:
method GetFunctionTestMixin.test_with_sharedict()