diff --git a/distributed/shuffle/_core.py b/distributed/shuffle/_core.py index 010d7d880d..a3f9ce327d 100644 --- 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