done

ray-project · Sep 19, 2024 · bd8238c · bd8238c
1 parent a6d438b
commit bd8238c
Showing 1 changed file with 2 additions and 1 deletion.
diff --git a/python/ray/experimental/channel/common.py b/python/ray/experimental/channel/common.py
@@ -473,7 +473,8 @@ def write(self, val: Any, timeout: Optional[float] = None) -> None:
         # If it is an exception, there's only 1 return value.
         # We have to send the same data to all channels.
         if isinstance(val, Exception):
-            val = tuple(val for _ in range(len(self._output_channels)))
+            if len(self._output_channels) > 1:
+                val = tuple(val for _ in range(len(self._output_channels)))
 
         if not self._is_input:
             if len(self._output_channels) > 1: