Method run

src/system.py:23–41

(self, user_input: str)

        )

    def run(self, user_input: str) -> None:
        graph = self.workflow_manager.get_graph()
        
        # Use factory function for consistent state initialization
        initial_state = create_initial_state(user_input)
        
        events = graph.stream(
            initial_state,
            {"configurable": {"thread_id": "1"}, "recursion_limit": 3000},
            stream_mode="values",
            debug=False
        )
        
        for event in events:
            message = event["messages"][-1]
            if isinstance(message, tuple):
                print(message, end='', flush=True)
            else:
                message.pretty_print()

if __name__ == "__main__":
    system = MultiAgentSystem()