[ADAG]Redundant code optimization (#50305)

Signed-off-by: noemotiovon <[email protected]>
ray-project · Feb 24, 2025 · e6bde94 · e6bde94
1 parent f100fe8
commit e6bde94
Showing 1 changed file with 2 additions and 7 deletions.
diff --git a/python/ray/dag/compiled_dag_node.py b/python/ray/dag/compiled_dag_node.py
@@ -497,12 +497,7 @@ def __init__(
 
         for arg in resolved_args:
             if isinstance(arg, ChannelInterface):
-                if isinstance(arg, ChannelInterface):
-                    channel = arg
-                else:
-                    adapter = arg
-                    channel = adapter.get_dag_input_channel()
-
+                channel = arg
                 if channel in input_channel_to_idx:
                     # The same channel was added before, so reuse the index.
                     channel_idx = input_channel_to_idx[channel]
@@ -2728,7 +2723,7 @@ def _visualize_ascii(self) -> str:
             # |                             |---------------------------->|                            # noqa
             # |                             9:Output[0]                   10:Output[1]                 # noqa
             # |<----------------------------------------------------------|                            # noqa
-            # 8:MultiOutputNod
+            # 8:MultiOutputNode
             ```
         """