Method split

runtime/node/splitter.py:158–187

Split by extracting array items from JSON content.

(self, inputs: List[Message])

        return [current]

    def split(self, inputs: List[Message]) -> List[List[Message]]:
        """Split by extracting array items from JSON content."""
        units: List[List[Message]] = []
        
        for msg in inputs:
            text = msg.text_content()
            
            # Try to parse as JSON
            try:
                data = json.loads(text)
                items = self._extract_array(data)
                
                for item in items:
                    if isinstance(item, (dict, list)):
                        content = json.dumps(item, ensure_ascii=False)
                    else:
                        content = str(item)
                    
                    unit_msg = Message(
                        role=msg.role,
                        content=content,
                        metadata={**msg.metadata, "split_source": "json_path"},
                    )
                    units.append([unit_msg])
                    
            except json.JSONDecodeError:
                # If not valid JSON, treat as single unit
                units.append([msg])
        
        return units if units else [[msg] for msg in inputs]


def create_splitter(