Block fusion for barrier tasks (#8944)

dask · Nov 20, 2024 · 0d905d5 · 0d905d5
1 parent ecb97dd
commit 0d905d5
Showing 1 changed file with 4 additions and 0 deletions.
diff --git a/distributed/shuffle/_core.py b/distributed/shuffle/_core.py
@@ -601,3 +601,7 @@ def __init__(
 
     def __repr__(self) -> str:
         return f"P2PBarrierTask({self.key!r})"
+
+    @property
+    def block_fusion(self) -> bool:
+        return True