Upgrading dask 0.7 to 0.8
Unknown0.7.6 → 0.8.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 corrcoef - added:
export cumprod - added:
export cumsum - added:
export eye - added:
export tril - added:
export triu
- removed:
function compute_broadcast(expr, *data, **kwargs) - removed:
function compute_it(expr, leaves, *data, **kwargs) - removed:
function compute_up(expr, data, **kwargs) - removed:
function elemwise_array(expr, *data, **kwargs) - removed:
function optimize_array(expr, *data)
- removed:
function broadcast_to(array, shape, subok=…) - added:
variable broadcast_to - added:
variable nancumprod - added:
variable nancumsum - added:
variable nanprod
- changed:
function insert_to_ooc(out, arr) → function insert_to_ooc(out, arr, lock=…) - changed:
function store(sources, targets, **kwargs) → function store(sources, targets, lock=…, compute=…, **kwargs) - added:
function corrcoef(x, y=…, rowvar=…) - added:
function diag(v) - added:
function eye(N, chunks, M=…, k=…, dtype=…) - added:
function tril(m, k=…) - added:
function triu(m, k=…) - added:
method Array.cumprod(axis, dtype=…) - added:
method Array.cumsum(axis, dtype=…) - added:
method Array.to_imperative()
- removed:
function diag(v)
- removed:
function array_to_dask(x, name=…, blockshape=…, **kwargs) - removed:
function dask_to_float(x, **kwargs) - removed:
function dask_to_numpy(x, **kwargs) - removed:
function discover_dask_array(a, **kwargs) - removed:
function resize(x, size) - removed:
function store_Array_in_ooc_data(out, arr, inplace=…, **kwargs) - removed:
variable arrays
- added:
function cholesky(a, lower=…) - added:
function inv(a) - added:
function lstsq(a, b) - added:
function lu(a) - added:
function solve(a, b, sym_pos=…) - added:
function solve_triangular(a, b, lower=…)
- removed:
variable divide - added:
function broadcast_to(array, shape, subok=…) - added:
function nancumprod(a, axis=…, dtype=…, out=…) - added:
function nancumsum(a, axis=…, dtype=…, out=…) - added:
function nanprod(a, axis=…, dtype=…, out=…, keepdims=…)
- changed:
function arg_chunk(func, argfunc, x, axis=…, **kwargs) → function arg_chunk(func, argfunc, x, axis, offset_info) - changed:
function arg_reduction(func, argfunc) → function arg_reduction(x, chunk, combine, agg, axis=…, split_every=…) - changed:
function reduction(x, chunk, aggregate, axis=…, keepdims=…, dtype=…, split_every=…, combine=…) → function reduction(x, chunk, aggregate, axis=…, keepdims=…, dtype=…, split_every=…, combine=…, name=…) - added:
function cumprod(x, axis, dtype=…) - added:
function cumreduction(func, binop, ident, x, axis, dtype=…) - added:
function cumsum(x, axis, dtype=…) - added:
function make_arg_reduction(func, argfunc, is_nan_func=…) - added:
function nanarg_agg(func, argfunc, data, axis=…, **kwargs)
- added:
function check_index(ind, dimension)
- removed:
export from_hdfs - added:
export from_imperative - added:
export range - added:
export zip
- removed:
function from_hdfs(path, hdfs=…, host=…, port=…, user_name=…) - removed:
variable load_names - removed:
variable names - removed:
variable tokens - changed:
function to_textfiles(b, path, name_function=…, compression=…, encoding=…) → function to_textfiles(b, path, name_function=…, compression=…, encoding=…, compute=…) - changed:
method Bag.all() → method Bag.all(split_every=…) - changed:
method Bag.any() → method Bag.any(split_every=…) - changed:
method Bag.count() → method Bag.count(split_every=…) - changed:
method Bag.fold(binop, combine=…, initial=…) → method Bag.fold(binop, combine=…, initial=…, split_every=…) - changed:
method Bag.frequencies() → method Bag.frequencies(split_every=…) - changed:
method Bag.map(func) → method Bag.map(func, **kwargs) - changed:
method Bag.map_partitions(func) → method Bag.map_partitions(func, **kwargs) - changed:
method Bag.max() → method Bag.max(split_every=…) - changed:
method Bag.min() → method Bag.min(split_every=…) - changed:
method Bag.reduction(perpartition, aggregate) → method Bag.reduction(perpartition, aggregate, split_every=…, out_type=…, name=…) - changed:
method Bag.sum() → method Bag.sum(split_every=…) - changed:
method Bag.to_textfiles(path, name_function=…, compression=…, encoding=…) → method Bag.to_textfiles(path, name_function=…, compression=…, encoding=…, compute=…) - changed:
method Bag.topk(k, key=…) → method Bag.topk(k, key=…, split_every=…) - added:
function bag_range(n, npartitions) - added:
function bag_zip(*bags) - added:
function from_imperative(values) - added:
function merge_frequencies(seqs) - added:
function unpack_kwargs(kwargs) - added:
method Bag.repartition(npartitions) - added:
method Bag.to_imperative() - added:
method Item.to_imperative() - added:
static method Item.from_imperative(value)
- removed:
function bag_to_iterator(x, **kwargs)
- added:
class LZMAFile - added:
constructor LZMAFile(*args, **kwargs) - added:
variable reduce
- added:
export from_imperative - added:
export melt
- added:
function categorize(df, columns=…, **kwargs) - added:
function get_categories(df) - added:
function iscategorical(dt) - added:
function strip_categories(df)
- removed:
class Accessor(object) - removed:
class DataFrame(_Frame) - removed:
class DatetimeAccessor(Accessor) - removed:
class GroupBy(_GroupBy) - removed:
class Index(Series) - removed:
class Scalar(Base) - removed:
class Series(_Frame) - removed:
class SeriesGroupBy(_GroupBy) - removed:
class StringAccessor(Accessor) - removed:
constructor Accessor(series) - removed:
constructor GroupBy(df, index=…, key=…, **kwargs) - removed:
constructor Scalar(dsk, _name, name=…, divisions=…) - removed:
constructor SeriesGroupBy(df, index, key=…, **kwargs) - removed:
field DatetimeAccessor.ns - removed:
field StringAccessor.ns - removed:
function apply_concat_apply(args, chunk=…, aggregate=…, columns=…, token=…) - removed:
function categorize(df, columns=…, **kwargs) - removed:
function categorize_block(df, categories) - removed:
function elemwise(op, *args, **kwargs) - removed:
function elemwise_property(attr, s) - removed:
function empty_safe(func, arg) - removed:
function finalize(results) - removed:
function map_partitions(func, columns, *args, **kwargs) - removed:
function nlargest(df, n=…, columns=…) - removed:
function optimize(dsk, keys, **kwargs) - removed:
function pd_split(df, p, random_state=…) - removed:
function quantile(df, q) - removed:
function reduction(x, chunk, aggregate, token=…) - removed:
function remove_empties(seq) - removed:
function repartition(df, divisions, force=…) - removed:
function repartition_divisions(a, b, name, out1, out2, force=…) - removed:
method DataFrame.append(other) - removed:
method DataFrame.apply(func, axis=…, args=…, columns=…, **kwds) - removed:
method DataFrame.assign(**kwargs) - removed:
method DataFrame.categorize(columns=…, **kwargs) - removed:
method DataFrame.drop(labels, axis=…) - removed:
method DataFrame.dropna(how=…, subset=…) - removed:
method DataFrame.groupby(key, **kwargs) - removed:
method DataFrame.iterrows() - removed:
method DataFrame.itertuples() - removed:
method DataFrame.join(other, on=…, how=…, lsuffix=…, rsuffix=…, npartitions=…) - removed:
method DataFrame.merge(right, how=…, on=…, left_on=…, right_on=…, left_index=…, right_index=…, suffixes=…, npartitions=…) - removed:
method DataFrame.nlargest(n=…, columns=…) - removed:
method DataFrame.query(expr, **kwargs) - removed:
method DataFrame.rename(index=…, columns=…) - removed:
method DataFrame.reset_index() - removed:
method DataFrame.set_index(other, **kwargs) - removed:
method DataFrame.set_partition(column, divisions, **kwargs) - removed:
method DataFrame.to_bag(index=…) - removed:
method DataFrame.to_castra(fn=…, categories=…, sorted_index_column=…, compute=…) - removed:
method GroupBy.apply(func, columns=…) - removed:
method Index.count() - removed:
method Index.max() - removed:
method Index.min() - removed:
method Index.nunique() - removed:
method Series.apply(func, convert_dtype=…, name=…, args=…, **kwds) - removed:
method Series.astype(dtype) - removed:
method Series.between(left, right, inclusive=…) - removed:
method Series.clip(lower=…, upper=…) - removed:
method Series.count() - removed:
method Series.cummax(axis=…, skipna=…) - removed:
method Series.cummin(axis=…, skipna=…) - removed:
method Series.cumprod(axis=…, skipna=…) - removed:
method Series.cumsum(axis=…, skipna=…) - removed:
method Series.dropna() - removed:
method Series.dt() - removed:
method Series.groupby(index, **kwargs) - removed:
method Series.isin(other) - removed:
method Series.iteritems() - removed:
method Series.map(arg, na_action=…) - removed:
method Series.max(axis=…, skipna=…) - removed:
method Series.mean(axis=…, skipna=…) - removed:
method Series.min(axis=…, skipna=…) - removed:
method Series.nlargest(n=…) - removed:
method Series.notnull() - removed:
method Series.nunique() - removed:
method Series.quantile(q=…) - removed:
method Series.resample(rule, how=…, axis=…, fill_method=…, closed=…, label=…, convention=…, kind=…, loffset=…, limit=…, base=…) - removed:
method Series.std(axis=…, ddof=…, skipna=…) - removed:
method Series.str() - removed:
method Series.sum(axis=…, skipna=…) - removed:
method Series.to_bag(index=…) - removed:
method Series.to_frame(name=…) - removed:
method Series.value_counts() - removed:
method Series.var(axis=…, ddof=…, skipna=…) - removed:
method SeriesGroupBy.apply(func, columns=…) - removed:
method SeriesGroupBy.nunique() - removed:
property DataFrame.column_info - removed:
property DataFrame.dtypes - removed:
property DataFrame.ndim - removed:
property GroupBy.column_info - removed:
property Index.index - removed:
property Series.column_info - removed:
property Series.columns - removed:
property Series.dtype - removed:
property Series.nbytes - removed:
property Series.ndim - removed:
property SeriesGroupBy.column_info - removed:
static method DatetimeAccessor.call(obj, attr, *args) - removed:
static method DatetimeAccessor.getattr(obj, attr) - removed:
static method StringAccessor.call(obj, attr, *args) - removed:
static method StringAccessor.getattr(obj, attr) - removed:
variable Cache - removed:
variable aca - removed:
variable no_default - removed:
variable return_scalar
- added:
class DataFrameGroupBy(_GroupBy) - added:
class SeriesGroupBy(_GroupBy) - added:
constructor DataFrameGroupBy(df, index=…, slice=…, **kwargs) - added:
constructor SeriesGroupBy(df, index, slice=…, **kwargs) - added:
method SeriesGroupBy.nunique() - added:
property DataFrameGroupBy.column_info - added:
property SeriesGroupBy.column_info
- removed:
function pdmerge(left, right, how, left_on, right_on, left_index, right_index, suffixes, default_left_columns, default_right_columns) - added:
function melt(frame, id_vars=…, value_vars=…, var_name=…, value_name=…, col_level=…)
- changed:
function set_index(df, index, npartitions=…, compute=…, **kwargs) → function set_index(df, index, npartitions=…, compute=…, drop=…, **kwargs) - changed:
function set_partition(df, index, divisions, compute=…, **kwargs) → function set_partition(df, index, divisions, compute=…, drop=…, **kwargs)
- added:
class Resampler(object) - added:
constructor Resampler(obj, rule, **kwargs) - added:
function getnanos(rule) - added:
method Resampler.count() - added:
method Resampler.first() - added:
method Resampler.last() - added:
method Resampler.max() - added:
method Resampler.mean() - added:
method Resampler.median() - added:
method Resampler.min() - added:
method Resampler.ohlc() - added:
method Resampler.prod() - added:
method Resampler.sem() - added:
method Resampler.std() - added:
method Resampler.sum() - added:
method Resampler.var()
- removed:
export Client - removed:
export Scheduler - removed:
export Worker - removed:
export dask_client_from_ipclient
- removed:
class Client(object) - removed:
constructor Client(scheduler, address=…) - removed:
function log(*args) - removed:
method Client.close(close_scheduler=…) - removed:
method Client.close_scheduler() - removed:
method Client.get(dsk, keys, keep_results=…) - removed:
method Client.get_collection(name) - removed:
method Client.get_registered_workers() - removed:
method Client.recv_from_scheduler() - removed:
method Client.register_client() - removed:
method Client.scheduler_status() - removed:
method Client.send_recv(header, payload) - removed:
method Client.send_to_scheduler(header, payload) - removed:
method Client.set_collection(name, collection) - removed:
variable context - removed:
variable jobids
- removed:
function dask_client_from_ipclient(ipclient)
- removed:
class Worker(object) - removed:
constructor Worker(scheduler, data=…, nthreads=…, hostname=…, port_to_workers=…, bind_to_workers=…, block=…, heartbeat=…) - removed:
function log(*args) - removed:
function logerrors() - removed:
function pickle_dumps(obj) - removed:
function status() - removed:
method Worker.block() - removed:
method Worker.close() - removed:
method Worker.close_from_scheduler(header, payload) - removed:
method Worker.collect(locations) - removed:
method Worker.compute(header, payload) - removed:
method Worker.delitem(header, payload) - removed:
method Worker.getitem_ack(header, payload) - removed:
method Worker.getitem_scheduler(header, payload) - removed:
method Worker.getitem_worker(header, payload) - removed:
method Worker.heart(pulse=…) - removed:
method Worker.listen_to_scheduler() - removed:
method Worker.listen_to_workers() - removed:
method Worker.send_to_scheduler(header, payload) - removed:
method Worker.send_to_worker(address, header, payload) - removed:
method Worker.setitem(header, payload) - removed:
method Worker.status_to_scheduler(header, payload) - removed:
method Worker.status_to_worker(header, payload) - removed:
method Worker.worker_death(header, payload) - removed:
variable MAX_DEALERS
- removed:
function filenames(hdfs, path)
- removed:
function do(func, pure=…) - added:
variable do
- removed:
export PBag - removed:
export dump - removed:
export load
- removed:
class PBag(object) - removed:
constructor PBag(grouper, npartitions, path=…, open=…, dump=…, load=…) - removed:
function isempty(seq) - removed:
function partition_all(n, seq) - removed:
method PBag.drop() - removed:
method PBag.extend(seq) - removed:
method PBag.extend_chunk(seq) - removed:
method PBag.get_partition(i) - removed:
method PBag.partition_of(item) - removed:
variable global_chunksize
- removed:
variable dump
- removed:
export cframe - removed:
export from_blocks - removed:
export pframe - removed:
export to_blocks
- removed:
function categorical_metadata(df) - removed:
function reapply_categories(df, metadata) - removed:
function strip_categories(df)
- removed:
class cframe(object) - removed:
constructor cframe(df, rootdir=…, chunklen=…, **kwargs) - removed:
method cframe.append(df) - removed:
method cframe.drop() - removed:
method cframe.flush() - removed:
method cframe.head(n=…) - removed:
method cframe.to_dataframe(columns=…) - removed:
property cframe.cbytes - removed:
property cframe.nbytes
- removed:
function from_blocks(blocks, index, columns, placement) - removed:
function to_blocks(df)
- removed:
class pframe(object) - removed:
constructor pframe(like, divisions, path=…, **kwargs) - removed:
function shard_df_on_index(df, divisions) - removed:
method pframe.append(df) - removed:
method pframe.drop() - removed:
method pframe.flush() - removed:
method pframe.get_partition(i, columns=…, has_lock=…) - removed:
method pframe.head(n=…) - removed:
method pframe.to_dataframe() - removed:
property pframe.cbytes - removed:
property pframe.nbytes - removed:
property pframe.npartitions
- removed:
function ignoring(*exc) - removed:
function raises(exc, lamda)