Function count

dask/dataframe/dask_expr/tests/test_map_partitions_overlap.py:363–366

(part)

)
def test_map_overlap_independent_operations_on_same_input(df, pdf, overlap_setup):
    def count(part):
        return_value = part.copy()
        return_value["count"] = len(return_value)
        return return_value

    before, after = overlap_setup