feat: future task UI (#8559)

* feat: future task UI

* fix: update filter label for UMO in English and Chinese locales

* feat: enhance cron job management with delivery target handling and UI improvements

* fix: update session label to indicate optional delivery target

* feat: add tooltip for last run time and error in cron job display

Author: Soulter

astrbot/core/cron/manager.py

@@ -15,6 +15,7 @@
 from astrbot.core.db import BaseDatabase
 from astrbot.core.db.po import CronJob
 from astrbot.core.platform.message_session import MessageSession
+from astrbot.core.platform.message_type import MessageType
 from astrbot.core.provider.entites import ProviderRequest
 from astrbot.core.utils.history_saver import persist_agent_history
 
@@ -200,9 +201,18 @@ def _get_next_run_time(self, job_id: str):
             return None
         return aps_job.next_run_time.astimezone(timezone.utc)
 
-    async def _run_job(self, job_id: str) -> None:
+    async def run_job_now(self, job_id: str) -> None:
+        await self._run_job(job_id, ignore_enabled=True, delete_run_once=False)
+
+    async def _run_job(
+        self,
+        job_id: str,
+        *,
+        ignore_enabled: bool = False,
+        delete_run_once: bool = True,
+    ) -> None:
         job = await self.db.get_cron_job(job_id)
-        if not job or not job.enabled:
+        if not job or (not job.enabled and not ignore_enabled):
             return
         start_time = datetime.now(timezone.utc)
         await self.db.update_cron_job(
@@ -230,7 +240,7 @@ async def _run_job(self, job_id: str) -> None:
                 last_error=last_error,
                 next_run_time=next_run,
             )
-            if job.run_once:
+            if job.run_once and delete_run_once:
                 # one-shot: remove after execution regardless of success
                 await self.delete_job(job_id)
 
@@ -245,9 +255,14 @@ async def _run_basic_job(self, job: CronJob) -> None:
 
     async def _run_active_agent_job(self, job: CronJob, start_time: datetime) -> None:
         payload = job.payload or {}
-        session_str = payload.get("session")
-        if not session_str:
-            raise ValueError("ActiveAgentCronJob missing session.")
+        delivery_session_str = str(payload.get("session") or "").strip()
+        session_str = delivery_session_str or str(
+            MessageSession(
+                platform_name="cron",
+                message_type=MessageType.OTHER_MESSAGE,
+                session_id=job.job_id,
+            )
+        )
         note = payload.get("note") or job.description or job.name
 
         extras = {
@@ -262,7 +277,7 @@ async def _run_active_agent_job(self, job: CronJob, start_time: datetime) -> Non
                 "run_at": (
                     job.payload.get("run_at") if isinstance(job.payload, dict) else None
                 ),
-                "session": session_str,
+                "session": delivery_session_str,
             },
             "cron_payload": payload,
         }
@@ -271,6 +286,7 @@ async def _run_active_agent_job(self, job: CronJob, start_time: datetime) -> Non
             message=note,
             session_str=session_str,
             extras=extras,
+            delivery_session_str=delivery_session_str,
         )
 
     async def _woke_main_agent(
@@ -279,6 +295,7 @@ async def _woke_main_agent(
         message: str,
         session_str: str,
         extras: dict,
+        delivery_session_str: str = "",
     ) -> None:
         """Woke the main agent to handle the cron job message."""
         from astrbot.core.astr_main_agent import (
@@ -353,11 +370,12 @@ async def _woke_main_agent(
             "Output using same language as previous conversation. "
             "After completing your task, summarize and output your actions and results."
         )
-        if not req.func_tool:
-            req.func_tool = ToolSet()
-        req.func_tool.add_tool(
-            self.ctx.get_llm_tool_manager().get_builtin_tool(SendMessageToUserTool)
-        )
+        if delivery_session_str:
+            if not req.func_tool:
+                req.func_tool = ToolSet()
+            req.func_tool.add_tool(
+                self.ctx.get_llm_tool_manager().get_builtin_tool(SendMessageToUserTool)
+            )
 
         result = await build_main_agent(
             event=cron_event, plugin_context=self.ctx, config=config, req=req

astrbot/dashboard/routes/cron.py

@@ -1,3 +1,4 @@
+import asyncio
 import traceback
 from datetime import datetime, timezone
 
@@ -15,11 +16,13 @@ def __init__(
     ) -> None:
         super().__init__(context)
         self.core_lifecycle = core_lifecycle
+        self._background_tasks: set[asyncio.Task] = set()
         self.routes = [
             ("/cron/jobs", ("GET", self.list_jobs)),
             ("/cron/jobs", ("POST", self.create_job)),
             ("/cron/jobs/<job_id>", ("PATCH", self.update_job)),
             ("/cron/jobs/<job_id>", ("DELETE", self.delete_job)),
+            ("/cron/jobs/<job_id>/run", ("POST", self.run_job_now)),
         ]
         self.register_routes()
 
@@ -71,16 +74,14 @@ async def create_job(self):
             name = payload.get("name") or "active_agent_task"
             cron_expression = payload.get("cron_expression")
             note = payload.get("note") or payload.get("description") or name
-            session = payload.get("session")
+            session = str(payload.get("session") or "").strip()
             persona_id = payload.get("persona_id")
             provider_id = payload.get("provider_id")
             timezone = payload.get("timezone")
             enabled = bool(payload.get("enabled", True))
             run_once = bool(payload.get("run_once", False))
             run_at = payload.get("run_at")
 
-            if not session:
-                return jsonify(Response().error("session is required").__dict__)
             if run_once and not run_at:
                 return jsonify(
                     Response().error("run_at is required when run_once=true").__dict__
@@ -172,11 +173,10 @@ async def update_job(self, job_id: str):
 
                 if "session" in payload:
                     session = str(payload.get("session") or "").strip()
-                    if not session:
-                        return jsonify(
-                            Response().error("session cannot be empty").__dict__
-                        )
-                    merged_payload["session"] = session
+                    if session:
+                        merged_payload["session"] = session
+                    else:
+                        merged_payload.pop("session", None)
 
                 note_updated = False
                 if "note" in payload:
@@ -281,3 +281,21 @@ async def delete_job(self, job_id: str):
         except Exception as e:  # noqa: BLE001
             logger.error(traceback.format_exc())
             return jsonify(Response().error(f"Failed to delete job: {e!s}").__dict__)
+
+    async def run_job_now(self, job_id: str):
+        try:
+            cron_mgr = self.core_lifecycle.cron_manager
+            if cron_mgr is None:
+                return jsonify(
+                    Response().error("Cron manager not initialized").__dict__
+                )
+            job = await cron_mgr.db.get_cron_job(job_id)
+            if not job:
+                return jsonify(Response().error("Job not found").__dict__)
+            task = asyncio.create_task(cron_mgr.run_job_now(job_id))
+            self._background_tasks.add(task)
+            task.add_done_callback(self._background_tasks.discard)
+            return jsonify(Response().ok(message="started").__dict__)
+        except Exception as e:  # noqa: BLE001
+            logger.error(traceback.format_exc())
+            return jsonify(Response().error(f"Failed to run job: {e!s}").__dict__)

dashboard/src/assets/mdi-subset/materialdesignicons-subset.css

@@ -1,4 +1,4 @@
-/* Auto-generated MDI subset – 268 icons */
+/* Auto-generated MDI subset – 271 icons */
 /* Do not edit manually. Run: pnpm run subset-icons */
 
 @font-face {
@@ -228,6 +228,10 @@
   content: "\F0150";
 }
 
+.mdi-clock-time-four-outline::before {
+  content: "\F144E";
+}
+
 .mdi-close::before {
   content: "\F0156";
 }
@@ -820,6 +824,10 @@
   content: "\F040A";
 }
 
+.mdi-play-circle-outline::before {
+  content: "\F040D";
+}
+
 .mdi-plus::before {
   content: "\F0415";
 }
@@ -892,6 +900,10 @@
   content: "\F167A";
 }
 
+.mdi-send-outline::before {
+  content: "\F1165";
+}
+
 .mdi-server::before {
   content: "\F048B";
 }

dashboard/src/assets/mdi-subset/materialdesignicons-webfont-subset.woff

@@ -6,8 +6,9 @@
   "page": {
     "title": "Future Task Management",
     "beta": "Experimental",
-    "subtitle": "See scheduled tasks for AstrBot. AstrBot will wake up, run them, and deliver the results.",
+    "subtitle": "AstrBot wakes up at the scheduled time, completes the task, and sends the result back to the target conversation.",
     "proactive": {
+      "link": "Supported platforms",
       "supported": "Proactive delivery is available only on the configured platforms below",
       "unsupported": "No proactive messaging platforms enabled. Turn them on in Platform settings."
     }
@@ -18,9 +19,36 @@
     "refresh": "Refresh",
     "delete": "Delete",
     "cancel": "Cancel",
+    "close": "Close",
+    "more": "More actions",
+    "runNow": "Run now",
     "save": "Save",
     "submit": "Create"
   },
+  "platformDialog": {
+    "title": "Supported Platforms",
+    "description": "Only the following platforms support proactive message delivery. AstrBot can send future task results back only to target conversations on these platforms."
+  },
+  "card": {
+    "onceAt": "One-off · {time}",
+    "runAt": "Run at: {time}",
+    "nextRun": "Next run: {time}",
+    "dailyAt": "Daily at {time}",
+    "weeklyAt": "Every {day} at {time}",
+    "monthlyAt": "Monthly on day {day} at {time}",
+    "everyMinutes": "Every {count} minutes",
+    "everyHours": "Every {count} hours",
+    "everyDays": "Every {count} days",
+    "customCron": "Custom · {cron}",
+    "noDeliveryTarget": "No delivery target"
+  },
+  "filters": {
+    "search": "Search title and content",
+    "umo": "Filter by delivery target",
+    "noUmos": "No UMOs",
+    "noDeliveryTarget": "No delivery target",
+    "noMatches": "No matching future tasks."
+  },
   "overview": {
     "totalTasks": "Total Tasks",
     "totalTasksNote": "Registered future tasks",
@@ -82,12 +110,43 @@
     "editTitle": "Edit Task",
     "chatHint": "You can ask AstrBot in chat to create future tasks instead of adding them here.",
     "runOnce": "One-off task",
-    "name": "Task name",
-    "note": "Task description",
-    "cron": "Cron expression",
+    "name": "Task name *",
+    "note": "Task requirements *",
+    "scheduleMode": "Execution time *",
+    "scheduleModes": {
+      "once": "One-off",
+      "interval": "Interval",
+      "daily": "Daily",
+      "weekly": "Weekly",
+      "monthly": "Monthly",
+      "cron": "Custom Cron"
+    },
+    "intervalEvery": "Every *",
+    "intervalUnit": "Unit *",
+    "intervalUnits": {
+      "minutes": "Minutes",
+      "hours": "Hours",
+      "days": "Days"
+    },
+    "dailyTime": "Time *",
+    "weeklyDay": "Weekday *",
+    "weeklyTime": "Time *",
+    "monthlyDay": "Day *",
+    "monthlyTime": "Time *",
+    "weekdays": {
+      "sunday": "Sunday",
+      "monday": "Monday",
+      "tuesday": "Tuesday",
+      "wednesday": "Wednesday",
+      "thursday": "Thursday",
+      "friday": "Friday",
+      "saturday": "Saturday"
+    },
+    "cron": "Cron expression *",
     "cronPlaceholder": "0 9 * * *",
-    "runAt": "Run at",
-    "session": "Target session (platform_id:message_type:session_id)",
+    "runAt": "Run at *",
+    "session": "Deliver to",
+    "noUmos": "No sessions available",
     "timezone": "Timezone (optional, e.g. Asia/Shanghai)",
     "enabled": "Enabled"
   },
@@ -97,11 +156,18 @@
     "updateFailed": "Failed to update",
     "deleteSuccess": "Deleted",
     "deleteFailed": "Failed to delete",
-    "sessionRequired": "Session is required",
-    "noteRequired": "Description is required",
+    "nameRequired": "Task name is required",
+    "sessionRequired": "Delivery target is required",
+    "noteRequired": "Task requirements are required",
     "cronRequired": "Cron expression is required",
     "runAtRequired": "Please select run time",
+    "intervalRequired": "Please enter a valid interval",
+    "dailyTimeRequired": "Please select the daily run time",
+    "weeklyTimeRequired": "Please select the weekly day and time",
+    "monthlyTimeRequired": "Please select the monthly day and time",
     "createSuccess": "Created successfully",
-    "createFailed": "Failed to create"
+    "createFailed": "Failed to create",
+    "runStarted": "Started",
+    "runFailed": "Failed to run"
   }
 }