Upgrading dask 0.8 to 0.9
Unknown0.8.2 → 0.9.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:
export from_delayed
- changed:
function from_imperative(value, shape, dtype=…, name=…) → function from_imperative(*args, **kwargs) - changed:
function partial_by_order(op, other) → function partial_by_order(*args, **kwargs) - added:
function from_delayed(value, shape, dtype=…, name=…) - added:
method Array.copy() - added:
method Array.to_delayed() - added:
property Array.A - added:
property Array.npartitions
- removed:
function fuse_slice_dict(match, getter=…) - removed:
function is_full_slice(task) - removed:
function remove_full_slices(dsk, keys) - removed:
variable a - removed:
variable b - removed:
variable rewrite_rules - removed:
variable x - added:
function optimize_slices(dsk)
- added:
variable randint - added:
variable random_integers
- removed:
export from_s3 - added:
export from_delayed - added:
export read_text
- removed:
function bz2_stream(compressed, chunksize=…) - removed:
function from_s3(bucket_name, paths=…, aws_access_key=…, aws_secret_key=…, connection=…, anon=…) - removed:
function normalize_s3_names(bucket_name, paths, conn_args) - removed:
function stream_decompress(fmt, data) - removed:
static method Bag.from_filenames(*args, **kwargs) - removed:
static method Bag.from_sequence(*args, **kwargs) - changed:
function inline_singleton_lists(dsk) → function inline_singleton_lists(dsk, dependencies=…) - added:
function from_delayed(values) - added:
method Bag.to_delayed() - added:
method Item.to_delayed() - added:
static method Item.from_delayed(value)
- added:
function decode(block, encoding, errors) - added:
function read_text(path, blocksize=…, compression=…, encoding=…, errors=…, linedelimiter=…, collection=…, **kwargs) - added:
variable delayed
- added:
export ignoring - added:
export local - added:
export open_files - added:
export open_text_files - added:
export read_bytes
- added:
function noop_file(file, **kwargs) - added:
variable compress - added:
variable decompress - added:
variable files - added:
variable seekable_files
- added:
function open_files(path, compression=…, **kwargs) - added:
function open_text_files(path, encoding=…, errors=…, compression=…, **kwargs) - added:
function read_bytes(path, delimiter=…, not_zero=…, blocksize=…, sample=…, compression=…, **kwargs) - added:
variable delayed
- added:
function getsize(fn, compression=…) - added:
function open_files(path) - added:
function open_text_files(path, encoding=…, errors=…) - added:
function read_block_from_file(fn, offset, length, delimiter, compression) - added:
function read_bytes(fn, delimiter=…, not_zero=…, blocksize=…, sample=…, compression=…) - added:
variable logger
- added:
function getsize(path, compression, s3) - added:
function open_files(path, s3=…, **s3_params) - added:
function read_block_from_s3(filename, offset, length, s3_params=…, delimiter=…, compression=…) - added:
function read_bytes(path, s3=…, delimiter=…, not_zero=…, blocksize=…, sample=…, compression=…, **s3_params) - added:
function s3_open_file(path, s3_params) - added:
variable logger
- added:
class SeekableFile(object) - added:
constructor SeekableFile(file) - added:
function read_block(f, offset, length, delimiter=…) - added:
function seek_delimiter(file, delimiter, blocksize) - added:
method SeekableFile.readable() - added:
method SeekableFile.seekable() - added:
method SeekableFile.writable() - added:
property SeekableFile.read1 - added:
variable SeekableFile
- changed:
constructor Callback(start=…, pretask=…, posttask=…, finish=…) → constructor Callback(start=…, start_state=…, pretask=…, posttask=…, finish=…)
- added:
function gzip_compress(b) - added:
function gzip_decompress(b) - added:
variable FileNotFoundError - added:
variable LZMA_AVAILABLE
- changed:
function toposort(dsk) → function toposort(dsk, dependencies=…)
- added:
export from_delayed
- added:
function bytes_read_csv(b, header, kwargs, dtypes=…, columns=…) - added:
function coerce_dtypes(df, dtypes) - added:
function read_csv(filename, blocksize=…, chunkbytes=…, collection=…, lineterminator=…, compression=…, enforce_dtypes=…, sample=…, **kwargs) - added:
function read_csv_from_bytes(block_lists, header, head, kwargs, collection=…, enforce_dtypes=…) - added:
variable delayed
- changed:
function collect(group, p, barrier_token) → function collect(group, p, meta, barrier_token) - added:
function hash_series(s) - added:
function partitioning_index(df, npartitions)
- added:
class Delayed(base.Base) - added:
constructor Delayed(name, dasks) - added:
function compute(*args, **kwargs) - added:
function delayed(obj, name=…, pure=…) - added:
property Delayed.dask - added:
property Delayed.key - added:
variable do
- removed:
class Value(base.Base) - removed:
constructor Value(name, dasks) - removed:
function compute(*args, **kwargs) - removed:
function value(val, name=…) - removed:
property Value.dask - removed:
property Value.key - removed:
variable do
- changed:
function fuse(dsk, keys=…) → function fuse(dsk, keys=…, dependencies=…) - changed:
function inline(dsk, keys=…, inline_constants=…) → function inline(dsk, keys=…, inline_constants=…, dependencies=…) - changed:
function inline_functions(dsk, output, fast_functions=…, inline_constants=…) → function inline_functions(dsk, output, fast_functions=…, inline_constants=…, dependencies=…)
- changed:
function order(dsk) → function order(dsk, dependencies=…)
- changed:
function filetexts(d, open=…) → function filetexts(d, open=…, mode=…) - changed:
function funcname(func) → function funcname(func, full=…) - added:
function ensure_bytes(s)
- added:
class GetFunctionTestCase(unittest.TestCase) - added:
field GetFunctionTestCase.get - added:
function add(x, y) - added:
function inc(x) - added:
method GetFunctionTestCase.runTest() - added:
method GetFunctionTestCase.test_badkey() - added:
method GetFunctionTestCase.test_data_not_in_dict_is_ok() - added:
method GetFunctionTestCase.test_get() - added:
method GetFunctionTestCase.test_get_stack_limit() - added:
method GetFunctionTestCase.test_get_with_list() - added:
method GetFunctionTestCase.test_get_with_nested_list() - added:
method GetFunctionTestCase.test_get_works_with_unhashables_in_values() - added:
method GetFunctionTestCase.test_nested_badkey() - added:
method GetFunctionTestCase.test_nested_tasks()