Update

dask · Dec 5, 2023 · 4004fda · 4004fda
1 parent 80d0054
commit 4004fda
Show file tree

Hide file tree

Showing 2 changed files with 6 additions and 4 deletions.
diff --git a/dask_expr/_collection.py b/dask_expr/_collection.py
@@ -728,8 +728,12 @@ def merge(
         npartitions : int, optional
             The number of output partitions
         broadcast : float, bool, optional
-            Whether to perform a broadcast merge if bool, or the broadcast bias if
-            it is a float.
+            Whether to use a broadcast-based join in lieu of a shuffle-based join for
+            supported cases. By default, a simple heuristic will be used to select
+            the underlying algorithm. If a floating-point value is specified, that
+            number will be used as the broadcast_bias within the simple heuristic
+            (a large number makes Dask more likely to choose the broacast_join code
+            path). See broadcast_join for more information.
         """
         return merge(
             self,

diff --git a/dask_expr/_merge.py b/dask_expr/_merge.py
@@ -240,14 +240,12 @@ def _lower(self):
                         left = Shuffle(
                             left,
                             shuffle_left_on,
-                            backend="tasks",
                             npartitions_out=right.npartitions,
                         )
                     else:
                         right = Shuffle(
                             right,
                             shuffle_right_on,
-                            backend="tasks",
                             npartitions_out=right.npartitions,
                         )