Source: dask Version: 2024.12.1+dfsg-2 Severity: serious Tags: forky sid User: [email protected] Usertags: python3.14
Hi maintainer The autopkgtests of this package fail with Python 3.14 [1]. I've copied what I hope is the relevant part of the log below. Regards Graham [1] https://ci.debian.net/packages/d/dask/testing/amd64/ 1569s =================================== FAILURES =================================== 1569s ___________________ test_multiple_repartition_partition_size ___________________ 1569s 1569s def test_multiple_repartition_partition_size(): 1569s b = db.from_sequence(range(1, 100), npartitions=1) 1569s total_mem = sum(b.map_partitions(total_mem_usage).compute()) 1569s 1569s c = b.repartition(partition_size=(total_mem // 2)) 1569s assert c.npartitions >= 2 1569s assert_eq(b, c) 1569s 1569s > d = c.repartition(partition_size=(total_mem // 5)) 1569s ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ 1569s 1569s /usr/lib/python3/dist-packages/dask/bag/tests/test_bag.py:1305: 1569s _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ 1569s /usr/lib/python3/dist-packages/dask/bag/core.py:1702: in repartition 1569s return repartition_size(self, partition_size) 1569s ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ 1569s /usr/lib/python3/dist-packages/dask/bag/core.py:2666: in repartition_size 1569s mem_usages = bag.map_partitions(total_mem_usage).compute() 1569s ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ 1569s /usr/lib/python3/dist-packages/dask/base.py:372: in compute 1569s (result,) = compute(self, traverse=False, **kwargs) 1569s ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ 1569s /usr/lib/python3/dist-packages/dask/base.py:660: in compute 1569s results = schedule(dsk, keys, **kwargs) 1569s ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ 1569s /usr/lib/python3/dist-packages/dask/bag/core.py:2655: in total_mem_usage 1569s partition = reify(deepcopy(partition)) 1569s ^^^^^^^^^^^^^^^^^ 1569s _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ 1569s 1569s > rv = reductor(4) 1569s E TypeError: cannot pickle 'itertools.chain' object 1569s 1569s /usr/lib/python3.14/copy.py:146: TypeError 1569s ____________________ test_enforce_columns[read_csv-blocks0] ____________________ 1569s 1569s reader = <function read_csv at 0x7f8d0198e090> 1569s blocks = [[b'aa,bb\n1,1.0\n2,2.0', b'10,20\n30,40'], [b'AA,bb\n1,1.0\n2,2.0', b'10,20\n30,40']] 1569s 1569s @pytest.mark.parametrize( 1569s "reader,blocks", [(pd.read_csv, csv_blocks), (pd.read_table, tsv_blocks)] 1569s ) 1569s def test_enforce_columns(reader, blocks): 1569s # Replace second header with different column name 1569s blocks = [blocks[0], [blocks[1][0].replace(b"a", b"A"), blocks[1][1]]] 1569s head = reader(BytesIO(blocks[0][0]), header=0) 1569s header = blocks[0][0].split(b"\n")[0] + b"\n" 1569s > with pytest.raises(ValueError): 1569s ^^^^^^^^^^^^^^^^^^^^^^^^^ 1569s E Failed: DID NOT RAISE <class 'ValueError'> 1569s 1569s /usr/lib/python3/dist-packages/dask/dataframe/io/tests/test_csv.py:353: Failed 1569s ___________________ test_enforce_columns[read_table-blocks1] ___________________ 1569s 1569s reader = <function read_table at 0x7f8d0198e770> 1569s blocks = [[b'aa\tbb\n1\t1.0\n2\t2.0', b'10\t20\n30\t40'], [b'AA\tbb\n1\t1.0\n2\t2.0', b'10\t20\n30\t40']] 1569s 1569s @pytest.mark.parametrize( 1569s "reader,blocks", [(pd.read_csv, csv_blocks), (pd.read_table, tsv_blocks)] 1569s ) 1569s def test_enforce_columns(reader, blocks): 1569s # Replace second header with different column name 1569s blocks = [blocks[0], [blocks[1][0].replace(b"a", b"A"), blocks[1][1]]] 1569s head = reader(BytesIO(blocks[0][0]), header=0) 1569s header = blocks[0][0].split(b"\n")[0] + b"\n" 1569s > with pytest.raises(ValueError): 1569s ^^^^^^^^^^^^^^^^^^^^^^^^^ 1569s E Failed: DID NOT RAISE <class 'ValueError'> 1569s 1569s /usr/lib/python3/dist-packages/dask/dataframe/io/tests/test_csv.py:353: Failed
