Upgrading dask 0.20 to 1
Unknown0.20.2 → 1.2.2
UnknownUpgrade verdict
None of the 10 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.
- removed:
export ignoring - added:
export backends - added:
export blockwise - added:
export diagonal - added:
export from_tiledb - added:
export ma - added:
export nancumprod - added:
export nancumsum - added:
export nanprod - added:
export reduction - added:
export to_tiledb - added:
export trace
- added:
function register_cupy() - added:
function register_scipy_sparse() - added:
function register_sparse()
- added:
function atop(*args, **kwargs) - added:
function blockwise(func, out_ind, *args, **kwargs)
- removed:
function einsum(*operands, **kwargs)
- removed:
function broadcast_dimensions(argpairs, numblocks, sentinels=…, consolidate=…) - removed:
function ndimlist(seq) - removed:
function register_cupy() - removed:
function register_scipy_sparse() - removed:
function register_sparse() - removed:
function zero_broadcast_dimensions(lol, nblocks) - changed:
function from_array(x, chunks, name=…, lock=…, asarray=…, fancy=…, getitem=…) → function from_array(x, chunks=…, name=…, lock=…, asarray=…, fancy=…, getitem=…) - changed:
function from_zarr(url, component=…, storage_options=…, chunks=…, **kwargs) → function from_zarr(url, component=…, storage_options=…, chunks=…, name=…, **kwargs) - added:
method Array.to_tiledb(uri, *args, **kwargs) - added:
method Array.trace(offset=…, axis1=…, axis2=…, dtype=…) - added:
variable einsum_lookup
- added:
function diagonal(a, offset=…, axis1=…, axis2=…)
- removed:
variable einsum_can_optimize - added:
function chunk_einsum(*operands, **kwargs)
- added:
function average(a, axis=…, weights=…, returned=…)
- removed:
function nancumprod(a, axis=…, dtype=…, out=…) - removed:
function nancumsum(a, axis=…, dtype=…, out=…)
- changed:
function percentile(a, q, interpolation=…) → function percentile(a, q, interpolation=…, method=…)
- changed:
method RandomState.randint(low, high=…, size=…, chunks=…) → method RandomState.randint(low, high=…, size=…, chunks=…, dtype=…)
- changed:
function mean_agg(pair, dtype=…, **kwargs) → function mean_agg(pairs, dtype=…, axis=…, **kwargs) - changed:
function mean_combine(pair, sum=…, numel=…, dtype=…, **kwargs) → function mean_combine(pairs, sum=…, numel=…, dtype=…, axis=…, **kwargs) - changed:
function moment_agg(data, order=…, ddof=…, dtype=…, sum=…, **kwargs) → function moment_agg(pairs, order=…, ddof=…, dtype=…, sum=…, axis=…, **kwargs) - changed:
function moment_combine(data, order=…, ddof=…, dtype=…, sum=…, **kwargs) → function moment_combine(pairs, order=…, ddof=…, dtype=…, sum=…, axis=…, **kwargs) - added:
function trace(a, offset=…, axis1=…, axis2=…, dtype=…)
- changed:
function dstack(tup) → function dstack(tup, allow_unknown_chunksizes=…) - changed:
function hstack(tup) → function hstack(tup, allow_unknown_chunksizes=…) - changed:
function vstack(tup) → function vstack(tup, allow_unknown_chunksizes=…)
- added:
function from_tiledb(uri, attribute=…, chunks=…, storage_options=…, **kwargs) - added:
function to_tiledb(darray, uri, compute=…, return_stored=…, storage_options=…, **kwargs)
- removed:
class TOP(Mapping) - removed:
constructor TOP(output, output_indices, dsk, indices, numblocks, concatenate=…, new_axes=…) - removed:
function atop(func, out_ind, *args, **kwargs) - removed:
function atop_token(i, prefix=…) - removed:
function index_subs(ind, substitution) - removed:
function lol_tuples(head, ind, values, dummies) - removed:
function optimize_atop(full_graph, keys=…) - removed:
function rewrite_atop(inputs) - removed:
function subs(task, substitution) - removed:
function top(func, output, out_indices, *arrind_pairs, **kwargs)
- added:
variable IS_NEP18_ACTIVE
- changed:
function inline_singleton_lists(dsk, dependencies=…) → function inline_singleton_lists(dsk, keys, dependencies=…) - changed:
function merge_distinct(seqs) → function merge_distinct(seqs, key=…) - changed:
method Bag.distinct() → method Bag.distinct(key=…) - changed:
method Bag.fold(binop, combine=…, initial=…, split_every=…) → method Bag.fold(binop, combine=…, initial=…, split_every=…, out_type=…) - added:
function chunk_distinct(seq, key=…)
- added:
class Blockwise(Mapping) - added:
constructor Blockwise(output, output_indices, dsk, indices, numblocks, concatenate=…, new_axes=…) - added:
function blockwise(func, output, output_indices, *arrind_pairs, **kwargs) - added:
function blockwise_token(i, prefix=…) - added:
function broadcast_dimensions(argpairs, numblocks, sentinels=…, consolidate=…) - added:
function index_subs(ind, substitution) - added:
function lol_tuples(head, ind, values, dummies) - added:
function make_blockwise_graph(func, output, out_indices, *arrind_pairs, **kwargs) - added:
function optimize_blockwise(graph, keys=…) - added:
function rewrite_blockwise(inputs) - added:
function subs(task, substitution) - added:
function zero_broadcast_dimensions(lol, nblocks)
- changed:
constructor HTTPFileSystem(**storage_options) → constructor HTTPFileSystem(simple_links=…, block_size=…, same_schema=…, **storage_options) - changed:
method HTTPFileSystem.glob(url) → method HTTPFileSystem.glob(path) - added:
method HTTPFileSystem.isdir(path) - added:
method HTTPFileSystem.ls(url, detail=…) - added:
variable ex - added:
variable ex2
- added:
function update_hdfs_options(options)
- removed:
function normalize_key(key) - removed:
function normalize_nested_keys(config) - added:
function canonical_name(k, config) - added:
variable fn
- changed:
function get(d, x, recursive=…, cache=…) → function get(dsk, out, cache=…)
- added:
export backends - added:
export read_fwf
- changed:
method StringAccessor.split(pat=…, n=…) → method StringAccessor.split(pat=…, n=…, expand=…)
- changed:
function apply_and_enforce(func, args, kwargs, meta) → function apply_and_enforce(*args, **kwargs) - changed:
function quantile(df, q) → function quantile(df, q, method=…) - changed:
method DataFrame.append(other) → method DataFrame.append(other, interleave_partitions=…) - changed:
method DataFrame.dropna(how=…, subset=…) → method DataFrame.dropna(how=…, subset=…, thresh=…) - changed:
method DataFrame.itertuples() → method DataFrame.itertuples(index=…, name=…) - changed:
method DataFrame.set_index(other, drop=…, sorted=…, npartitions=…, divisions=…, **kwargs) → method DataFrame.set_index(other, drop=…, sorted=…, npartitions=…, divisions=…, inplace=…, **kwargs) - changed:
method Series.quantile(q=…) → method Series.quantile(q=…, method=…) - added:
function has_parallel_type(x) - added:
function meta_warning(df) - added:
function partitionwise_graph(func, name, *args, **kwargs) - added:
method Index.to_frame(index=…, name=…)
- added:
variable make_array_nonempty
- changed:
constructor SeriesGroupBy(df, by=…, slice=…) → constructor SeriesGroupBy(df, by=…, slice=…, **kwargs)
- removed:
function hash_array(vals, encoding=…, hash_key=…, categorize=…) - removed:
function hash_object_array(x, hash_key, encoding) - removed:
function hash_pandas_object(obj, index=…, encoding=…, hash_key=…, categorize=…)
- added:
export read_fwf
- added:
variable read_fwf
- changed:
function make_timeseries(start=…, end=…, dtypes=…, freq=…, partition_freq=…, seed=…) → function make_timeseries(start=…, end=…, dtypes=…, freq=…, partition_freq=…, seed=…, **kwargs)
- changed:
function read_json(url_path, orient=…, lines=…, storage_options=…, blocksize=…, sample=…, encoding=…, errors=…, compression=…, **kwargs) → function read_json(url_path, orient=…, lines=…, storage_options=…, blocksize=…, sample=…, encoding=…, errors=…, compression=…, meta=…, **kwargs)
- removed:
function merge(left, right, how, left_on, right_on, left_index, right_index, indicator, suffixes, default_left, default_right) - added:
function assign_index(df, ind)
- changed:
function merge_indexed_dataframes(lhs, rhs, how=…, lsuffix=…, rsuffix=…, indicator=…, left_on=…, right_on=…, left_index=…, right_index=…) → function merge_indexed_dataframes(lhs, rhs, left_index=…, right_index=…, **kwargs) - added:
function merge_chunk(lhs, *args, **kwargs)
- changed:
function make_meta_index(x) → function make_meta_index(x, index=…) - changed:
function make_meta_pandas(x) → function make_meta_pandas(x, index=…) - added:
function is_dataframe_like(df) - added:
function is_index_like(s) - added:
function is_integer_na_dtype(t) - added:
function is_series_like(s) - added:
function valid_divisions(divisions) - added:
variable HAS_INT_NA - added:
variable PANDAS_GT_0240 - added:
variable is_interval_dtype
- changed:
function timeseries(start=…, end=…, freq=…, partition_freq=…, dtypes=…, seed=…) → function timeseries(start=…, end=…, freq=…, partition_freq=…, dtypes=…, seed=…, **kwargs)
- added:
function graphviz_to_file(g, filename, format)
- added:
class HighLevelGraph(Mapping) - added:
constructor HighLevelGraph(layers, dependencies) - added:
function to_graphviz(hg, data_attributes=…, function_attributes=…, rankdir=…, graph_attr=…, node_attr=…, edge_attr=…, **kwargs) - added:
method HighLevelGraph.items() - added:
method HighLevelGraph.visualize(filename=…, format=…, **kwargs) - added:
property HighLevelGraph.dicts - added:
static method HighLevelGraph.from_collections(name, layer, dependencies=…) - added:
static method HighLevelGraph.merge(*graphs)
- changed:
function get(dsk, keys, num_workers=…, func_loads=…, func_dumps=…, optimize_graph=…, **kwargs) → function get(dsk, keys, num_workers=…, func_loads=…, func_dumps=…, optimize_graph=…, pool=…, **kwargs)
- added:
function register_cupy()
- removed:
export Store
- removed:
class Store(MutableMapping) - removed:
constructor Store(cache=…)
- changed:
function get(dsk, result, cache=…, num_workers=…, **kwargs) → function get(dsk, result, cache=…, num_workers=…, pool=…, **kwargs)
- removed:
property SerializableLock.locked - changed:
method SerializableLock.acquire(*args) → method SerializableLock.acquire(*args, **kwargs) - changed:
method SerializableLock.release(*args) → method SerializableLock.release(*args, **kwargs) - added:
function ignore_warning(doc, cls, name, extra=…) - added:
function ndimlist(seq) - added:
function typename(typ) - added:
function unsupported_arguments(doc, args) - added:
method SerializableLock.locked()
- removed:
method GetFunctionTestMixin.test_with_sharedict() - added:
method GetFunctionTestMixin.test_with_HighLevelGraph()