Method run_session

internagent/mas/interface.py:165–200

Execute a research session. Args: session_id: ID of the session to run status_callback: Optional callback for state change notifications Signature: (session_id, old_state, new_state) -> None Returns: Current se

(self,
                        session_id: str,
                        status_callback: Optional[Callable[[str, str, str], None]] = None)

        return session_id

    async def run_session(self,
                        session_id: str,
                        status_callback: Optional[Callable[[str, str, str], None]] = None) -> Dict[str, Any]:
        """
        Execute a research session.

        Args:
            session_id: ID of the session to run
            status_callback: Optional callback for state change notifications
                           Signature: (session_id, old_state, new_state) -> None

        Returns:
            Current session status

        Raises:
            RuntimeError: If system is not ready
        """
        self._ensure_system_ready()

        # Create state change handler
        async def on_state_change(session, old_state, new_state):
            self._update_session_tracking(session_id, new_state.value)

            if status_callback:
                try:
                    await status_callback(session_id, old_state.value, new_state.value)
                except Exception as e:
                    logger.error(f"Error in status callback: {str(e)}")

        # Execute session
        await self.orchestration_agent.run_session(
            session_id=session_id,
            on_state_change=on_state_change
        )

        return await self.get_session_status(session_id)

    async def add_feedback(self,
                         session_id: str,