diff --git a/dask/bag/core.py b/dask/bag/core.py index c1bb53d9bf4..756b876c861 100644 --- a/dask/bag/core.py +++ b/dask/bag/core.py @@ -1601,7 +1601,10 @@ def to_delayed(self, optimize_graph=True): return [Delayed(k, dsk) for k in keys] def repartition(self, npartitions): - """ Coalesce bag into fewer partitions. + """ Changes the number of partitions of the bag. + + This can be used to reduce or increase the number of partitions + of the bag. Examples --------