shards should never be empty

dask · Nov 7, 2023 · 1b26ec6 · 1b26ec6
1 parent 3f840d7
commit 1b26ec6
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/distributed/shuffle/_disk.py b/distributed/shuffle/_disk.py
@@ -163,7 +163,7 @@ async def _process(self, id: str, shards: list[Any]) -> None:
 
                     frames: Iterable[bytes | bytearray | memoryview]
 
-                    if not shards or isinstance(shards[0], bytes):
+                    if isinstance(shards[0], bytes):
                         # Manually serialized dataframes
                         frames = shards
                     else: