Method split

runtime/node/splitter.py:19–28

Split inputs into execution units. Args: inputs: Input messages to split Returns: List of message groups, each group is one execution unit

(self, inputs: List[Message])

    @abstractmethod
    def split(self, inputs: List[Message]) -> List[List[Message]]:
        """Split inputs into execution units.
        
        Args:
            inputs: Input messages to split
            
        Returns:
            List of message groups, each group is one execution unit
        """
        pass


class MessageSplitter(Splitter):