rock agentic swe agent impl (#143)

* feat: add rock agentic demo for swe agent

* feat: update logger print for swe agent

* fix: correct SweAgent import path

* feat: add base deps to sdk

* feat: update deps in pyproject.toml

* feat: update lock

* feat: add retry logic for swe-agent installation

Author: BCeZn

pyproject.toml

@@ -69,10 +69,15 @@ builder = [
     "docker"
 ]
 
+examples = [
+    "pyyaml"
+]
+
 all = [
     "rl-rock[admin]",
     "rl-rock[rocklet]",
     "rl-rock[builder]",
+    "rl-rock[examples]",
 ]
 
 [project.scripts]

rock/env_vars.py

@@ -1,3 +1,4 @@
+import json
 import os
 import sys
 from collections.abc import Callable
@@ -39,6 +40,10 @@
     # Model Service Config
     ROCK_MODEL_SERVICE_DATA_DIR: str
 
+    # Agentic
+    ROCK_AGENT_PRE_STARTUP_BASH_CMD_LIST: list[str] = []
+    ROCK_AGENT_PYTHON_INSTALL_CMD: str
+
 
 environment_variables: dict[str, Callable[[], Any]] = {
     "ROCK_LOGGING_PATH": lambda: os.getenv("ROCK_LOGGING_PATH"),
@@ -74,6 +79,11 @@
         "ROCK_CLI_DEFAULT_CONFIG_PATH", Path.home() / ".rock" / "config.ini"
     ),
     "ROCK_MODEL_SERVICE_DATA_DIR": lambda: os.getenv("ROCK_MODEL_SERVICE_DATA_DIR", "/data/logs"),
+    "ROCK_AGENT_PYTHON_INSTALL_CMD": lambda: os.getenv(
+        "ROCK_AGENT_PYTHON_INSTALL_CMD",
+        "[ -f cpython31114.tar.gz ] && rm cpython31114.tar.gz; [ -d python ] && rm -rf python; wget -q -O cpython31114.tar.gz https://github.com/astral-sh/python-build-standalone/releases/download/20251120/cpython-3.11.14+20251120-x86_64-unknown-linux-gnu-install_only.tar.gz && tar -xzf cpython31114.tar.gz",
+    ),
+    "ROCK_AGENT_PRE_STARTUP_BASH_CMD_LIST": lambda: json.loads(os.getenv("ROCK_AGENT_PRE_STARTUP_BASH_CMD_LIST", "[]")),
 }
 
 

rock/sdk/sandbox/agent/swe_agent.py

@@ -1,23 +1,304 @@
+"""
+SWE-agent Integration Module
+
+This module provides integration with SWE-agent (Software Engineering Agent) for automated
+software engineering tasks within a sandboxed environment. It handles the complete lifecycle
+of SWE-agent including environment initialization, dependency installation, and execution.
+
+Key Components:
+    - SweAgentConfig: Configuration dataclass for SWE-agent setup parameters
+    - SweAgent: Main agent implementation managing initialization and execution
+
+Usage Example:
+    ```python
+    from rock.sdk.sandbox.client import Sandbox
+
+    swe_agent_config = SweAgentConfig(
+        agent_type="swe-agent",
+        version="unknown",
+        swe_agent_workdir=self.sweagent_dir,
+        swe_session=self.swe_session,
+    )
+
+    sandbox = Sandbox(...)
+    sandbox.agent = SweAgent(sandbox, config)
+
+    await sandbox.agent.init()
+    await sandbox.agent.run("path/to/config.yaml")
+    ```
+
+Note:
+    Currently supports LocalDeployment and RunSingleConfig modes only.
+    Requires a Sandbox instance (not AbstractSandbox) for execution.
+"""
+
+import os
+import shlex
+from pathlib import Path
 from typing import Literal
 
+from rock import env_vars
 from rock.actions.sandbox.base import AbstractSandbox
+from rock.actions.sandbox.request import CreateBashSessionRequest, UploadRequest
+from rock.logger import init_logger
 from rock.sdk.sandbox.agent.base import Agent
 from rock.sdk.sandbox.agent.config import AgentConfig
+from rock.sdk.sandbox.client import Sandbox
+from rock.utils import retry_async
+
+logger = init_logger(__name__)
 
 
 class SweAgentConfig(AgentConfig):
+    """
+    Configuration dataclass for SWE-agent initialization and execution.
+
+    This class defines all configurable parameters for setting up and running
+    SWE-agent in a sandboxed environment, including installation commands,
+    working directories, and execution timeouts.
+
+    Attributes:
+        agent_type: Fixed identifier for this agent type ("swe-agent")
+        swe_session: Name of the bash session used for SWE-agent execution
+        pre_startup_bash_cmd_list: Commands executed before agent initialization
+        post_startup_bash_cmd_list: Commands executed after agent initialization
+        swe_agent_workdir: Working directory for agent installation and execution
+        python_install_cmd: Command to install Python environment
+        swe_agent_install_cmd: Command to clone and install SWE-agent repository
+        python_install_timeout: Maximum seconds to wait for Python installation
+        swe_agent_install_timeout: Maximum seconds to wait for SWE-agent installation
+        agent_run_timeout: Maximum seconds to wait for agent execution completion
+        agent_run_check_interval: Seconds between status checks during execution
+    """
+
     agent_type: Literal["swe-agent"] = "swe-agent"
 
+    swe_session: str = "swe-agent-session"
+
+    # Commands to execute before agent initialization (e.g., bashrc setup, hosts config)
+    pre_startup_bash_cmd_list: list[str] = env_vars.ROCK_AGENT_PRE_STARTUP_BASH_CMD_LIST
+
+    # Commands to execute after agent initialization
+    post_startup_bash_cmd_list: list[str] = []
+
+    # Working directory where SWE-agent will be installed and executed
+    swe_agent_workdir: str = "/tmp_sweagent"
+
+    # Command to download and set up Python environment
+    python_install_cmd: str = env_vars.ROCK_AGENT_PYTHON_INSTALL_CMD
+
+    # Command to clone SWE-agent repository and install dependencies
+    swe_agent_install_cmd: str = "[ -d SWE-agent ] && rm -rf SWE-agent; git clone https://github.com/SWE-agent/SWE-agent.git && cd SWE-agent && pip install -e . -i https://mirrors.aliyun.com/pypi/simple/"
+
+    python_install_timeout: int = 300
+
+    swe_agent_install_timeout: int = 600
+
+    agent_run_timeout: int = 1800
+
+    agent_run_check_interval: int = 30
+
 
 class SweAgent(Agent):
+    """
+    SWE-agent implementation for automated software engineering tasks.
+
+    This class manages the complete lifecycle of SWE-agent including environment
+    initialization, dependency installation, and task execution within a sandboxed
+    environment. It provides an asynchronous interface for agent operations.
+
+    Attributes:
+        config: Configuration parameters for agent setup and execution
+        swe_session: Name of the bash session used for agent operations
+
+    Note:
+        Currently requires a Sandbox instance (not AbstractSandbox).
+        Only supports LocalDeployment and RunSingleConfig modes.
+    """
+
     def __init__(self, sandbox: AbstractSandbox, config: SweAgentConfig):
+        """
+        Initialize SWE-agent with sandbox environment and configuration.
+
+        Args:
+            sandbox: Sandbox instance for isolated agent execution
+            config: Configuration parameters for agent setup
+
+        Raises:
+            AssertionError: If sandbox is not an instance of Sandbox class
+        """
         super().__init__(sandbox)
         self.config = config
+        self.swe_session = self.config.swe_session
 
     async def init(self):
-        # Initialization logic for SWE agent
-        pass
+        """
+        Initialize the SWE-agent environment within the sandbox.
+
+        Performs the following initialization steps in sequence:
+        1. Creates a dedicated bash session for agent execution
+        2. Executes pre-startup configuration commands
+        3. Creates working directory for agent installation
+        4. Installs Python environment
+        5. Clones and installs SWE-agent from GitHub repository
+
+        The initialization process is asynchronous and uses the configured
+        timeouts for long-running operations like dependency installation.
+
+        Raises:
+            Exception: If any initialization step fails
+        """
+        assert isinstance(self._sandbox, Sandbox), "Sandbox must be an instance of Sandbox class"
+
+        sandbox_id = self._sandbox.sandbox_id
+
+        logger.info(f"[{sandbox_id}] Starting SWE-agent initialization")
+
+        # Step 1: Create dedicated bash session for agent operations
+        logger.info(f"[{sandbox_id}] Creating bash session: {self.swe_session}")
+        await self._sandbox.create_session(
+            CreateBashSessionRequest(
+                session=self.swe_session,
+                env_enable=True,
+            )
+        )
+
+        # Step 2: Execute pre-startup configuration commands
+        logger.info(f"[{sandbox_id}] Executing {len(self.config.pre_startup_bash_cmd_list)} pre-startup commands")
+        for idx, cmd in enumerate(self.config.pre_startup_bash_cmd_list, 1):
+            logger.debug(f"→ Pre-startup command {idx}/{len(self.config.pre_startup_bash_cmd_list)}: {cmd[:100]}...")
+            await self._sandbox.arun(
+                cmd=cmd,
+                session=self.swe_session,
+            )
+
+        # Step 3: Create working directory structure
+        logger.info(f"[{sandbox_id}] Creating working directory: {self.config.swe_agent_workdir}")
+        await self._sandbox.arun(
+            cmd=f"mkdir -p {self.config.swe_agent_workdir}",
+            session=self.swe_session,
+        )
+
+        # Step 4: Install Python environment with retry
+        logger.info(f"[{sandbox_id}] Installing Python environment")
+
+        python_install_cmd = f"cd {self.config.swe_agent_workdir} && {self.config.python_install_cmd}"
+        await self._arun_with_retry(
+            cmd=f"bash -c {shlex.quote(python_install_cmd)}",
+            session=self.swe_session,
+            mode="nohup",
+            wait_timeout=self.config.python_install_timeout,
+            error_msg="Python installation failed",
+        )
+        logger.info(f"[{sandbox_id}] Python installation completed")
+
+        # Step 5: Install SWE-agent repository with retry
+        # Note: Temporarily using standalone pip from installed Python
+        logger.info(f"[{sandbox_id}] Installing SWE-agent from repository")
+
+        swe_agent_install_cmd = f"export PATH={self.config.swe_agent_workdir}/python/bin:$PATH && cd {self.config.swe_agent_workdir} && {self.config.swe_agent_install_cmd}"
+        await self._arun_with_retry(
+            cmd=f"bash -c {shlex.quote(swe_agent_install_cmd)}",
+            session=self.swe_session,
+            mode="nohup",
+            wait_timeout=self.config.swe_agent_install_timeout,
+            error_msg="SWE-agent installation failed",
+        )
+        logger.info(f"[{sandbox_id}] SWE-agent installation completed successfully")
+
+    @retry_async(max_attempts=3, delay_seconds=5.0, backoff=2.0)
+    async def _arun_with_retry(
+        self,
+        cmd: str,
+        session: str,
+        mode: str = "nohup",
+        wait_timeout: int = 300,
+        wait_interval: int = 10,
+        error_msg: str = "Command failed",
+    ):
+        """
+        Execute a command with retry logic based on exit code.
+
+        Args:
+            cmd: Command to execute
+            session: Session name to execute command in
+            mode: Execution mode (normal, nohup, etc.)
+            wait_timeout: Timeout for command execution
+            wait_interval: Check interval for nohup commands
+            error_msg: Error message to use when raising exception
+
+        Returns:
+            Command result upon success
+        """
+        result = await self._sandbox.arun(
+            cmd=cmd, session=session, mode=mode, wait_timeout=wait_timeout, wait_interval=wait_interval
+        )
+        # If exit_code is not 0, raise an exception to trigger retry
+        if result.exit_code != 0:
+            raise Exception(f"{error_msg} with exit code: {result.exit_code}, output: {result.output}")
+        return result
+
+    async def run(self, swe_agent_config_path: str | Path):
+        """
+        Execute SWE-agent with the specified configuration file.
+
+        This method uploads the configuration file to the sandbox and executes
+        SWE-agent with monitoring for completion. The execution runs in nohup
+        mode with periodic status checks based on the configured interval.
+
+        Args:
+            swe_agent_config_path: Local path to the SWE-agent configuration file
+                                   (YAML format). The file will be uploaded to the
+                                   sandbox before execution.
+
+        Returns:
+            CommandResult: Execution result containing exit code, stdout, and stderr
+
+        Raises:
+            AssertionError: If sandbox is not an instance of Sandbox class
+            Exception: If file upload or command execution fails
+
+        Example:
+            ```python
+            result = await agent.run("configs/swe_task.yaml")
+            if result.exit_code == 0:
+                print("Agent completed successfully")
+            ```
+        """
+        assert isinstance(self._sandbox, Sandbox), "Sandbox must be an instance of Sandbox class"
+
+        logger.info(f"→ Starting SWE-agent execution with config: {swe_agent_config_path}")
+
+        config_filename = Path(swe_agent_config_path).name
+
+        # Upload configuration file to sandbox working directory
+        logger.info(f"↑ Uploading configuration file: {config_filename}")
+        await self._sandbox.upload(
+            UploadRequest(
+                source_path=os.path.abspath(swe_agent_config_path),
+                target_path=f"{self.config.swe_agent_workdir}/{config_filename}",
+            )
+        )
+        logger.debug(f"✓ Configuration file uploaded to: {self.config.swe_agent_workdir}/{config_filename}")
+
+        # Construct and execute SWE-agent run command
+        swe_agent_run_cmd = f"cd {self.config.swe_agent_workdir} && {self.config.swe_agent_workdir}/python/bin/sweagent run --config {config_filename}"
+        logger.info(
+            f"▶ Executing SWE-agent (timeout: {self.config.agent_run_timeout}s, check interval: {self.config.agent_run_check_interval}s)"
+        )
+
+        result = await self._sandbox.arun(
+            cmd=f"bash -c {shlex.quote(swe_agent_run_cmd)}",
+            session=self.swe_session,
+            mode="nohup",
+            wait_timeout=self.config.agent_run_timeout,
+            wait_interval=self.config.agent_run_check_interval,
+        )
+
+        # Log execution outcome
+        if result.exit_code == 0:
+            logger.info(f"✓ SWE-agent completed successfully (exit_code: {result.exit_code})")
+        else:
+            logger.error(f"✗ SWE-agent failed with exit_code: {result.exit_code}")
 
-    async def run(self, **kwargs):
-        # Execution logic for SWE agent
-        pass
+        return result