Fix/file not found handle 0205

docs/i18n/zh-Hans/docusaurus-plugin-content-docs/version-1.2.x/Release Notes/index.md

@@ -2,4 +2,5 @@
 sidebar_position: 1
 ---
 # 版本说明
-* [release v1.2.0](v1.2.0.md)
+* [release v1.2.0](v1.2.0.md)
+* [release v1.2.1](v1.2.1.md)

docs/i18n/zh-Hans/docusaurus-plugin-content-docs/version-1.2.x/Release Notes/v1.2.1.md

@@ -0,0 +1,17 @@
+# v1.2.1
+
+## 发布日期
+2026 年 2 月 5 日
+
+## 概述
+本次发布主要涉及Admin的bug修复。
+
+---
+
+## Admin
+
+### Bug 修复
+
+#### 任务调度器
+
+修复了任务状态文件在worker中缺失检测不到的问题。

docs/versioned_docs/version-1.2.x/Release Notes/index.md

@@ -3,3 +3,4 @@ sidebar_position: 1
 ---
 # Release Notes
 * [release v1.2.0](v1.2.0.md)
+* [release v1.2.1](v1.2.1.md)

docs/versioned_docs/version-1.2.x/Release Notes/v1.2.1.md

@@ -0,0 +1,17 @@
+# v1.2.1
+
+## Release Date
+February 5, 2026
+
+## Overview
+This release primarily focuses on Admin bug fix.
+
+---
+
+## Admin
+
+### Bug Fixes
+
+#### Task Scheduler
+
+Fix an issue where missing task status files on workers were not detected.

pyproject.toml

@@ -7,7 +7,7 @@ build-backend = "setuptools.build_meta"
 authors = [{ name = "chatos@alibaba" }]
 requires-python = "<4.0,>=3.10"
 name = "rl-rock"
-version = "1.2.0"
+version = "1.2.1"
 description = "ROCK-Reinforcement Open Construction Kit"
 readme = "README.md"
 dependencies = [

rock/admin/scheduler/task_base.py

@@ -151,10 +151,9 @@ async def single_run(self, runtime: RemoteSandboxRuntime, ip: str) -> dict:
 
     async def get_task_status(self, runtime: RemoteSandboxRuntime) -> TaskStatus | None:
         """Get task status from worker."""
-        try:
-            await runtime.execute(Command(command=f"ls {self.status_file_path}", shell=True))
-        except Exception:
-            logger.info(f"{self.status_file_path} not found")
+        check_file_resp = await runtime.execute(Command(command=f"ls {self.status_file_path}", shell=True))
+        if check_file_resp.exit_code == 2:
+            logger.info(f"task status file not exist: {self.status_file_path}")
             return None
 
         response = await runtime.read_file(ReadFileRequest(path=self.status_file_path))