Upgrading dask 0.12 to 0.13
Unknown0.12.0 → 0.13.0
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.
- 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.
- removed:
property Array.dtype - changed:
constructor Array(dask, name, chunks, dtype=…, shape=…) → constructor Array(dask, name, chunks, dtype, shape=…) - changed:
function from_delayed(value, shape, dtype=…, name=…) → function from_delayed(value, shape, dtype, name=…) - changed:
function insert_to_ooc(out, arr, lock=…) → function insert_to_ooc(out, arr, lock=…, region=…) - changed:
function store(sources, targets, lock=…, compute=…, **kwargs) → function store(sources, targets, lock=…, regions=…, compute=…, **kwargs) - changed:
method Array.rechunk(chunks) → method Array.rechunk(chunks, threshold=…, block_size_limit=…) - added:
function apply_infer_dtype(func, args, kwargs, funcname=…) - added:
function slice_with_dask_array(x, index) - added:
property Array.itemsize
- changed:
method RandomState.gamma(shape, scale=…, chunks=…) → method RandomState.gamma(shape, scale=…, size=…, chunks=…)
- changed:
function intersect_chunks(old_chunks=…, new_chunks=…, shape=…) → function intersect_chunks(old_chunks, new_chunks) - changed:
function rechunk(x, chunks) → function rechunk(x, chunks, threshold=…, block_size_limit=…) - added:
function divide_to_width(desired_chunks, max_width) - added:
function estimate_graph_size(old_chunks, new_chunks) - added:
function find_merge_rechunk(old_chunks, new_chunks, block_size_limit) - added:
function find_split_rechunk(old_chunks, new_chunks, graph_size_limit) - added:
function format_blocks(blocks) - added:
function format_chunks(chunks) - added:
function format_plan(plan) - added:
function merge_to_number(desired_chunks, max_number) - added:
function plan_rechunk(old_chunks, new_chunks, itemsize, threshold=…, block_size_limit=…) - added:
variable DEFAULT_BLOCK_SIZE_LIMIT - added:
variable DEFAULT_THRESHOLD
- added:
function validate_axis(ndim, axis)
- added:
function file_to_blocks(lazy_file)
- added:
function get_xz_blocks(fp) - added:
function xz_decompress(data, check)
- removed:
function open_files_by(open_files_backend, path, compression=…, **kwargs) - removed:
variable delayed - changed:
function open_files(urlpath, compression=…, **kwargs) → function open_files(urlpath, compression=…, mode=…, encoding=…, errors=…, name_function=…, num=…, **kwargs) - changed:
function open_text_files(urlpath, encoding=…, errors=…, compression=…, **kwargs) → function open_text_files(urlpath, compression=…, mode=…, encoding=…, errors=…, **kwargs) - changed:
function write_block_to_file(data, f, compression, encoding) → function write_block_to_file(data, lazy_file) - added:
class FileSystem(object) - added:
class OpenFile(object) - added:
class OpenFileCreator(object) - added:
constructor OpenFile(myopen, path, compression, mode, text, encoding, errors=…) - added:
constructor OpenFileCreator(urlpath, compression=…, text=…, encoding=…, errors=…, **kwargs) - added:
function get_fs_paths_myopen(urlpath, compression, mode, encoding=…, num=…, name_function=…, **kwargs) - added:
function normalize_OpenFileCreator(ofc) - added:
function read_block_from_file(lazy_file, off, bs, delimiter) - added:
method FileSystem.get_block_locations(path) - added:
method FileSystem.logical_size(path, compression) - added:
method OpenFile.close()
- removed:
function getsize(path, compression=…) - removed:
function open_file_write(paths) - removed:
function open_file_write_direct(path) - removed:
function open_files(path) - removed:
function open_text_files(path, encoding=…, errors=…) - removed:
function read_block_from_file(path, offset, length, delimiter, compression) - removed:
function read_bytes(path, delimiter=…, not_zero=…, blocksize=…, sample=…, compression=…) - added:
class LocalFileSystem(core.FileSystem) - added:
constructor LocalFileSystem(**storage_options) - added:
field LocalFileSystem.sep - added:
method LocalFileSystem.glob(path) - added:
method LocalFileSystem.mkdirs(path) - added:
method LocalFileSystem.open(path, mode=…, **kwargs) - added:
method LocalFileSystem.size(path) - added:
method LocalFileSystem.ukey(path)
- removed:
function getsize(path, compression, s3) - removed:
function open_file_write(paths, s3=…, **kwargs) - removed:
function open_file_write_direct(path, s3=…, **kwargs) - removed:
function open_files(path, s3=…, **kwargs) - removed:
function read_block_from_s3(path, offset, length, s3=…, delimiter=…, compression=…, **kwargs) - removed:
function read_bytes(path, s3=…, delimiter=…, not_zero=…, blocksize=…, sample=…, compression=…, **kwargs) - removed:
function s3_open_file(path, s3=…, **kwargs) - added:
class DaskS3FileSystem(S3FileSystem, core.FileSystem) - added:
constructor DaskS3FileSystem(key=…, username=…, secret=…, password=…, path=…, host=…, s3=…, **kwargs) - added:
field DaskS3FileSystem.sep - added:
method DaskS3FileSystem.glob(path, **kwargs) - added:
method DaskS3FileSystem.mkdirs(path) - added:
method DaskS3FileSystem.open(path, mode=…, **kwargs) - added:
method DaskS3FileSystem.size(path) - added:
method DaskS3FileSystem.ukey(path)
- removed:
property SeekableFile.read1 - added:
method SeekableFile.read1(*args, **kwargs)
- removed:
variable GzipFile
- added:
export read_parquet - added:
export to_bag - added:
export to_delayed - added:
export to_hdf - added:
export to_parquet - added:
export to_records
- changed:
method DataFrameGroupBy.agg(arg, split_every=…) → method DataFrameGroupBy.agg(arg, split_every=…, split_out=…) - changed:
method DataFrameGroupBy.aggregate(arg, split_every=…) → method DataFrameGroupBy.aggregate(arg, split_every=…, split_out=…) - changed:
method SeriesGroupBy.agg(arg, split_every=…) → method SeriesGroupBy.agg(arg, split_every=…, split_out=…) - changed:
method SeriesGroupBy.aggregate(arg, split_every=…) → method SeriesGroupBy.aggregate(arg, split_every=…, split_out=…) - changed:
method SeriesGroupBy.nunique(split_every=…) → method SeriesGroupBy.nunique(split_every=…, split_out=…)
- added:
function hash_array(vals) - added:
function hash_pandas_object(obj, index=…)
- added:
function compute_first_bit(a) - added:
function compute_hll_array(obj, b) - added:
function estimate_count(Ms, b) - added:
function reduce_state(Ms, b)
- added:
export read_parquet - added:
export to_parquet - added:
export to_records
- added:
function normalize_ParquetFile(pf) - added:
function read_parquet(path, columns=…, filters=…, categories=…, index=…, storage_options=…) - added:
function to_parquet(path, df, compression=…, write_index=…, has_nulls=…, fixed_text=…, object_encoding=…, storage_options=…) - added:
variable default_encoding - added:
variable fastparquet
- added:
function boundary_slice(df, start, stop, right_boundary=…, left_boundary=…, kind=…) - added:
function drop_columns(df, columns, dtype) - added:
function fillna_check(df, method, check=…)
- removed:
function call_pandas_rolling_method_single(this_partition, rolling_kwargs, method_name, method_args, method_kwargs) - removed:
function call_pandas_rolling_method_with_neighbors(prev_partition, this_partition, next_partition, before, after, rolling_kwargs, method_name, method_args, method_kwargs) - removed:
function rolling_chunk(func, part1, part2, window, *args) - removed:
variable rolling_window - changed:
function wrap_rolling(func) → function wrap_rolling(func, method_name) - changed:
method Rolling.apply(*args, **kwargs) → method Rolling.apply(func, args=…, kwargs=…) - changed:
method Rolling.count(*args, **kwargs) → method Rolling.count() - changed:
method Rolling.kurt(*args, **kwargs) → method Rolling.kurt() - changed:
method Rolling.max(*args, **kwargs) → method Rolling.max() - changed:
method Rolling.mean(*args, **kwargs) → method Rolling.mean() - changed:
method Rolling.median(*args, **kwargs) → method Rolling.median() - changed:
method Rolling.min(*args, **kwargs) → method Rolling.min() - changed:
method Rolling.quantile(*args, **kwargs) → method Rolling.quantile(quantile) - changed:
method Rolling.skew(*args, **kwargs) → method Rolling.skew() - changed:
method Rolling.std(*args, **kwargs) → method Rolling.std(ddof=…) - changed:
method Rolling.sum(*args, **kwargs) → method Rolling.sum() - changed:
method Rolling.var(*args, **kwargs) → method Rolling.var(ddof=…) - added:
function map_overlap(func, df, before, after, *args, **kwargs) - added:
function overlap_chunk(func, prev_part, current_part, next_part, before, after, args, kwargs) - added:
function pandas_rolling_method(df, rolling_kwargs, name, *args, **kwargs) - added:
function rolling_window(arg, window, **kwargs)
- removed:
function hash_series(s) - changed:
function set_index(df, index, npartitions=…, shuffle=…, compute=…, drop=…, upsample=…, **kwargs) → function set_index(df, index, npartitions=…, shuffle=…, compute=…, drop=…, upsample=…, divisions=…, **kwargs)
- changed:
function funcname(func, full=…) → function funcname(func) - changed:
method Dispatch.register(type, func) → method Dispatch.register(type, func=…) - added:
class SerializableLock(object) - added:
constructor SerializableLock(token=…) - added:
function ensure_unicode(s) - added:
method Dispatch.register_lazy(toplevel, func=…) - added:
method SerializableLock.acquire(*args) - added:
method SerializableLock.release(*args) - added:
property SerializableLock.locked