chore: fix task status and bump version (#489)

Author: rayrayraykk

pyproject.toml

@@ -1,6 +1,6 @@
 [project]
 name = "agentscope-runtime"
-version = "1.1.4"
+version = "1.1.5"
 description = "A production-ready runtime framework for agent applications, providing secure sandboxed execution environments and scalable deployment solutions with multi-framework support."
 readme = "README.md"
 requires-python = ">=3.10"

src/agentscope_runtime/engine/deployers/utils/service_utils/fastapi_factory.py

@@ -1104,8 +1104,14 @@ async def task_status_handler(task_id: str):
 
                 # Align with BaseApp.get_task logic - map internal status to
                 # external status format
-                if task_status in ["submitted", "running"]:
+                if task_status == "submitted":
                     return {"status": "pending", "result": None}
+                if task_status == "running":
+                    return {
+                        "status": "running",
+                        "started_at": task_info.get("started_at"),
+                        "result": None,
+                    }
                 elif task_status == "completed":
                     return {
                         "status": "finished",

src/agentscope_runtime/engine/deployers/utils/service_utils/routing/task_engine_mixin.py

@@ -368,8 +368,14 @@ def get_task_status(self, task_id: str):
             task_info = self.active_tasks[task_id]
             task_status = task_info.get("status", "unknown")
 
-            if task_status in ["submitted", "running"]:
+            if task_status == "submitted":
                 return {"status": "pending", "result": None}
+            if task_status == "running":
+                return {
+                    "status": "running",
+                    "started_at": task_info.get("started_at"),
+                    "result": None,
+                }
             elif task_status == "completed":
                 return {
                     "status": "finished",

src/agentscope_runtime/version.py

@@ -1,2 +1,2 @@
 # -*- coding: utf-8 -*-
-__version__ = "v1.1.4"
+__version__ = "v1.1.5"

tests/integrated/test_agent_app_stream_task.py

@@ -191,7 +191,11 @@ async def test_get_task_status_pending(start_app):
             status_data = await resp.json()
 
             assert "status" in status_data
-            assert status_data["status"] in ["pending", "finished"]
+            assert status_data["status"] in [
+                "pending",
+                "running",
+                "finished",
+            ]
 
 
 @pytest.mark.asyncio