mirror of
https://github.com/OpenHands/OpenHands.git
synced 2025-12-26 05:48:36 +08:00
1356da8795
* feat: support controlling agent task state. * feat: add agent task state to agent status bar. * feat: add agent task control bar to FE. * Remove stop agent task action. * Merge pause and resume buttons into one button; Add loading and disabled status for action buttons. * Apply suggestions from code review --------- Co-authored-by: Robert Brennan <accounts@rbren.io>
54 lines
1.5 KiB
Python
54 lines
1.5 KiB
Python
from dataclasses import dataclass, field
|
|
|
|
from .base import ExecutableAction, NotExecutableAction
|
|
from opendevin.schema import ActionType
|
|
from opendevin.observation import NullObservation
|
|
|
|
from typing import TYPE_CHECKING
|
|
if TYPE_CHECKING:
|
|
from opendevin.controller import AgentController
|
|
|
|
|
|
@dataclass
|
|
class AddTaskAction(ExecutableAction):
|
|
parent: str
|
|
goal: str
|
|
subtasks: list = field(default_factory=list)
|
|
action: str = ActionType.ADD_TASK
|
|
|
|
async def run(self, controller: 'AgentController') -> NullObservation: # type: ignore
|
|
if controller.state is not None:
|
|
controller.state.plan.add_subtask(self.parent, self.goal, self.subtasks)
|
|
return NullObservation('')
|
|
|
|
@property
|
|
def message(self) -> str:
|
|
return f'Added task: {self.goal}'
|
|
|
|
|
|
@dataclass
|
|
class ModifyTaskAction(ExecutableAction):
|
|
id: str
|
|
state: str
|
|
action: str = ActionType.MODIFY_TASK
|
|
|
|
async def run(self, controller: 'AgentController') -> NullObservation: # type: ignore
|
|
if controller.state is not None:
|
|
controller.state.plan.set_subtask_state(self.id, self.state)
|
|
return NullObservation('')
|
|
|
|
@property
|
|
def message(self) -> str:
|
|
return f'Set task {self.id} to {self.state}'
|
|
|
|
|
|
@dataclass
|
|
class TaskStateChangedAction(NotExecutableAction):
|
|
"""Fake action, just to notify the client that a task state has changed."""
|
|
task_state: str
|
|
action: str = ActionType.CHANGE_TASK_STATE
|
|
|
|
@property
|
|
def message(self) -> str:
|
|
return f'Task state changed to {self.task_state}'
|