Upgrading dask 0.4 to 0.5
Unknown0.4.0 → 0.5.0
UnknownUpgrade verdict
The only release in this range publishes no 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.
- DepDelta found no commit log for them either.
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:
class Array(object) - added:
constructor Array(dask, name, chunks, dtype=…, shape=…) - added:
function around(x, decimals=…) - added:
function atop(func, out, out_ind, *args, **kwargs) - added:
function blockdims_from_blockshape(shape, blockshape) - added:
function broadcast_dimensions(argpairs, numblocks, sentinels=…) - added:
function broadcast_to(x, shape) - added:
function choose(a, choices) - added:
function coarsen(reduction, x, axes) - added:
function compute(*args, **kwargs) - added:
function concatenate(seq, axis=…) - added:
function dotmany(A, B, leftfunc=…, rightfunc=…, **kwargs) - added:
function elemwise(op, *args, **kwargs) - added:
function frexp(x) - added:
function from_array(x, chunks, name=…, lock=…, **kwargs) - added:
function fromfunction(func, chunks=…, shape=…, dtype=…) - added:
function get(dsk, keys, get=…, **kwargs) - added:
function getarray(a, b, lock=…) - added:
function getem(arr, chunks, shape=…) - added:
function insert(arr, obj, values, axis) - added:
function insert_to_ooc(out, arr) - added:
function isclose(arr1, arr2, rtol=…, atol=…, equal_nan=…) - added:
function isnull(values) - added:
function lol_tuples(head, ind, values, dummies) - added:
function many(a, b, binop=…, reduction=…, **kwargs) - added:
function map_blocks(x, func, chunks=…, dtype=…) - added:
function modf(x) - added:
function normalize_chunks(chunks, shape=…) - added:
function notnull(values) - added:
function offset_func(func, offset, *args) - added:
function partial_by_order(op, other) - added:
function rec_concatenate(arrays, axis=…) - added:
function slices_from_chunks(chunks) - added:
function split_at_breaks(array, breaks, axis=…) - added:
function squeeze(a, axis=…) - added:
function stack(seq, axis=…) - added:
function store(sources, targets, **kwargs) - added:
function take(a, indices, axis) - added:
function tensordot(lhs, rhs, axes=…) - added:
function top(func, output, out_indices, *arrind_pairs, **kwargs) - added:
function transpose(a, axes=…) - added:
function unique(x) - added:
function unpack_singleton(x) - added:
function variadic_choose(a, *choices) - added:
function where(condition, x, y) - added:
function wrap_elemwise(func, **kwargs) - added:
function write_hdf5_chunk(fn, datapath, index, data) - added:
function zero_broadcast_dimensions(lol, nblocks) - added:
method Array.all(axis=…, keepdims=…) - added:
method Array.any(axis=…, keepdims=…) - added:
method Array.argmax(axis=…) - added:
method Array.argmin(axis=…) - added:
method Array.astype(dtype, **kwargs) - added:
method Array.compute(**kwargs) - added:
method Array.dot(other) - added:
method Array.map_blocks(func, chunks=…, dtype=…) - added:
method Array.map_overlap(func, depth, boundary=…, trim=…, **kwargs) - added:
method Array.max(axis=…, keepdims=…) - added:
method Array.mean(axis=…, keepdims=…) - added:
method Array.min(axis=…, keepdims=…) - added:
method Array.prod(axis=…, keepdims=…) - added:
method Array.rechunk(chunks) - added:
method Array.squeeze() - added:
method Array.std(axis=…, keepdims=…, ddof=…) - added:
method Array.store(target, **kwargs) - added:
method Array.sum(axis=…, keepdims=…) - added:
method Array.to_hdf5(filename, datapath, **kwargs) - added:
method Array.transpose(axes=…) - added:
method Array.var(axis=…, keepdims=…, ddof=…) - added:
method Array.vnorm(ord=…, axis=…, keepdims=…) - added:
property Array.T - added:
property Array.dtype - added:
property Array.nbytes - added:
property Array.ndim - added:
property Array.numblocks - added:
property Array.shape - added:
property Array.size - added:
variable ALPHABET - added:
variable alphabet - added:
variable angle - added:
variable arccos - added:
variable arccosh - added:
variable arcsin - added:
variable arcsinh - added:
variable arctan - added:
variable arctan2 - added:
variable arctanh - added:
variable ceil - added:
variable clip - added:
variable concatenate_names - added:
variable conj - added:
variable copysign - added:
variable cos - added:
variable cosh - added:
variable deg2rad - added:
variable degrees - added:
variable exp - added:
variable expm1 - added:
variable fabs - added:
variable fix - added:
variable floor - added:
variable fmax - added:
variable fmin - added:
variable fmod - added:
variable fromfunction_names - added:
variable hypot - added:
variable imag - added:
variable iscomplex - added:
variable isfinite - added:
variable isinf - added:
variable isnan - added:
variable isreal - added:
variable ldexp - added:
variable log - added:
variable log10 - added:
variable log1p - added:
variable log2 - added:
variable logaddexp - added:
variable logaddexp2 - added:
variable logical_and - added:
variable logical_not - added:
variable logical_or - added:
variable logical_xor - added:
variable maximum - added:
variable minimum - added:
variable names - added:
variable nextafter - added:
variable rad2deg - added:
variable radians - added:
variable real - added:
variable rint - added:
variable sign - added:
variable signbit - added:
variable sin - added:
variable sinh - added:
variable sqrt - added:
variable square - added:
variable stacked_names - added:
variable tan - added:
variable tanh - added:
variable trunc
- changed:
function trim_internal(x, axes=…) → function trim_internal(x, axes) - added:
function map_overlap(x, func, depth, boundary=…, trim=…, **kwargs) - added:
function nearest(x, axis, depth)
- added:
function full(shape, fill_value, dtype=…, order=…) - added:
function isclose(*args, **kwargs) - added:
variable full - added:
variable isclose
- changed:
function finish_task(dsk, key, result, state, results) → function finish_task(dsk, key, state, results, delete=…, release_data=…) - changed:
function release_data(key, state) → function release_data(key, state, delete=…)
- added:
export concat - added:
export from_hdfs - added:
export to_textfiles
- added:
class StringAccessor(object) - added:
constructor StringAccessor(bag) - added:
function bz2_stream(compressed, chunksize=…) - added:
function concat(bags) - added:
function from_hdfs(path, hdfs=…, host=…, port=…, user_name=…) - added:
function robust_wraps(wrapper) - added:
function stream_decompress(fmt, data) - added:
function to_textfiles(b, path, name_function=…) - added:
function write(data, filename) - added:
method Bag.to_dataframe(columns=…) - added:
method Bag.to_textfiles(path, name_function=…) - added:
method StringAccessor.match(pattern)
- added:
export concat - added:
export optimize
- added:
function categories_and_quantiles(fn, args, kwargs, index=…, categorize=…, chunkbytes=…) - added:
function csv_names(fn, encoding=…, compression=…, names=…, parse_dates=…, **kwargs) - added:
function dataframe_from_ctable(x, slc, columns=…, categories=…) - added:
function file_size(fn, compression=…) - added:
function from_array(x, chunksize=…) - added:
function from_bcolz(x, chunksize=…, categorize=…, index=…, **kwargs) - added:
function infer_header(fn, encoding=…, compression=…, **kwargs) - added:
function read_csv(fn, *args, **kwargs) - added:
variable from_array_names
- added:
function optimize(dsk, keys, **kwargs) - added:
variable a - added:
variable b - added:
variable c - added:
variable d - added:
variable e - added:
variable rewrite_rules
- changed:
function set_partition(f, index, blockdivs, get=…, **kwargs) → function set_partition(f, index, divisions, get=…, **kwargs) - changed:
function unique(blockdivs) → function unique(divisions)
- added:
export Client - added:
export Scheduler - added:
export Worker
- added:
class Client(object) - added:
constructor Client(scheduler, address=…) - added:
function log(*args) - added:
method Client.close() - added:
method Client.get(dsk, keys) - added:
method Client.get_collection(name) - added:
method Client.recv_from_scheduler() - added:
method Client.scheduler_status() - added:
method Client.send_to_scheduler(header, payload) - added:
method Client.set_collection(name, collection) - added:
variable context - added:
variable jobids
- added:
class Worker(object) - added:
constructor Worker(scheduler, data=…, nthreads=…, hostname=…, port_to_workers=…, bind_to_workers=…, block=…) - added:
function log(*args) - added:
function logerrors() - added:
function pickle_dumps(obj) - added:
function status() - added:
method Worker.block() - added:
method Worker.close() - added:
method Worker.close_from_scheduler(header, payload) - added:
method Worker.collect(locations) - added:
method Worker.compute(header, payload) - added:
method Worker.delitem(header, payload) - added:
method Worker.getitem_ack(header, payload) - added:
method Worker.getitem_scheduler(header, payload) - added:
method Worker.getitem_worker(header, payload) - added:
method Worker.listen_to_scheduler() - added:
method Worker.listen_to_workers() - added:
method Worker.send_to_scheduler(header, payload) - added:
method Worker.send_to_worker(address, header, payload) - added:
method Worker.setitem(header, payload) - added:
method Worker.status_to_scheduler(header, payload) - added:
method Worker.status_to_worker(header, payload) - added:
variable MAX_DEALERS
- added:
function filenames(hdfs, path)
- added:
function textblock(file, start, stop, compression=…) - added:
variable opens
- changed:
constructor pframe(like, blockdivs, path=…, **kwargs) → constructor pframe(like, divisions, path=…, **kwargs) - changed:
function shard_df_on_index(df, blockdivs) → function shard_df_on_index(df, divisions)