fix(cron): report SQLite storage path in cron.status instead of legacy jobs.json (#92144)

liuhao1024 · web-flow · commit 047785eb30c0 · 2026-06-11T22:39:42.000+09:00
* fix(cron): report SQLite storage path in cron.status instead of legacy jobs.json The `cron.status` gateway response returned `storePath` pointing to the legacy `jobs.json` path, but cron jobs are actually stored in the shared SQLite state database. This misled operators and agents into looking for a JSON file that no longer exists. - Add `storage: "sqlite"` and `sqlitePath` fields to CronStatusSummary - Mark legacy `storePath` as @deprecated (kept for backward compat) - Update CLI warning to prefer sqlitePath over storePath - Add regression assertions in read-ops test Fixes #91766 * fix(macos): prefer sqlitePath in cron status display * fix(macos): add sqlitePath to CronSchedulerStatus type
diff --git a/apps/macos/Sources/OpenClaw/CronJobsStore.swift b/apps/macos/Sources/OpenClaw/CronJobsStore.swift
@@ -72,7 +72,7 @@ final class CronJobsStore {
         do {
             if let status = try? await GatewayConnection.shared.cronStatus() {
                 self.schedulerEnabled = status.enabled
-                self.schedulerStorePath = status.storePath
+                self.schedulerStorePath = status.sqlitePath ?? status.storePath
                 self.schedulerNextWakeAtMs = status.nextWakeAtMs
             }
             self.jobs = try await GatewayConnection.shared.cronList(includeDisabled: true)
diff --git a/apps/macos/Sources/OpenClaw/GatewayConnection.swift b/apps/macos/Sources/OpenClaw/GatewayConnection.swift
@@ -775,6 +775,7 @@ extension GatewayConnection {
     struct CronSchedulerStatus: Decodable {
         let enabled: Bool
         let storePath: String
+        let sqlitePath: String?
         let jobs: Int
         let nextWakeAtMs: Int?
     }
diff --git a/src/cli/cron-cli/shared.ts b/src/cli/cron-cli/shared.ts
@@ -176,11 +176,15 @@ export async function warnIfCronSchedulerDisabled(opts: GatewayRpcOpts) {
     const res = (await callGatewayFromCli("cron.status", opts, {})) as {
       enabled?: boolean;
       storePath?: string;
+      storage?: string;
+      sqlitePath?: string;
     };
     if (res?.enabled === true) {
       return;
     }
-    const store = typeof res?.storePath === "string" ? res.storePath : "";
+    const store = typeof res?.sqlitePath === "string" ? res.sqlitePath
+      : typeof res?.storePath === "string" ? res.storePath
+      : "";
     defaultRuntime.error(
       [
         "warning: cron scheduler is disabled in the Gateway; jobs are saved but will not run automatically.",
diff --git a/src/cron/service.read-ops-nonblocking.test.ts b/src/cron/service.read-ops-nonblocking.test.ts
@@ -83,6 +83,8 @@ function expectCronStatus(
 ) {
   expect(status.enabled).toBe(true);
   expect(status.storePath).toBe(params.storePath);
+  expect(status.storage).toBe("sqlite");
+  expect(status.sqlitePath).toContain("openclaw.sqlite");
   expect(status.jobs).toBe(params.jobs);
   if (status.nextWakeAtMs !== null) {
     expect(status.nextWakeAtMs).toBeTypeOf("number");
diff --git a/src/cron/service/ops.ts b/src/cron/service/ops.ts
@@ -3,6 +3,7 @@ import { normalizeLowercaseStringOrEmpty } from "@openclaw/normalization-core/st
 import { enqueueCommandInLane } from "../../process/command-queue.js";
 import { CommandLane } from "../../process/lanes.js";
 import { DEFAULT_AGENT_ID } from "../../routing/session-key.js";
+import { resolveOpenClawStateSqlitePath } from "../../state/openclaw-state-db.paths.js";
 import {
   completeTaskRunByRunId,
   createRunningTaskRun,
@@ -254,6 +255,8 @@ export async function status(state: CronServiceState) {
     return {
       enabled: state.deps.cronEnabled,
       storePath: state.deps.storePath,
+      storage: "sqlite" as const,
+      sqlitePath: resolveOpenClawStateSqlitePath(),
       jobs: state.store?.jobs.length ?? 0,
       nextWakeAtMs: state.deps.cronEnabled ? (nextWakeAtMs(state) ?? null) : null,
     };
diff --git a/src/cron/service/state.ts b/src/cron/service/state.ts
@@ -218,7 +218,12 @@ export type CronWakeMode = "now" | "next-heartbeat";
 /** Lightweight service status returned to gateway/control surfaces. */
 export type CronStatusSummary = {
   enabled: boolean;
+  /** @deprecated Legacy partition key; actual storage is SQLite. Use `sqlitePath`. */
   storePath: string;
+  /** Storage backend identifier. */
+  storage: "sqlite";
+  /** Resolved path to the shared state SQLite database. */
+  sqlitePath: string;
   jobs: number;
   nextWakeAtMs: number | null;
 };
diff --git a/src/plugins/contracts/scheduled-turns.contract.test.ts b/src/plugins/contracts/scheduled-turns.contract.test.ts
@@ -92,6 +92,8 @@ function createMockCronService(): CronServiceContract {
     status: vi.fn(async () => ({
       enabled: true,
       storePath: "/tmp/openclaw-test-cron.json",
+      storage: "sqlite" as const,
+      sqlitePath: "/tmp/openclaw-test-state/state/openclaw.sqlite",
       jobs: 0,
       nextWakeAtMs: null,
     })),

Original file line number	Diff line number	Diff line change
`@@ -72,7 +72,7 @@ final class CronJobsStore {`
`72`	`72`	`do {`
`73`	`73`	`if let status = try? await GatewayConnection.shared.cronStatus() {`
`74`	`74`	`self.schedulerEnabled = status.enabled`
`75`		`- self.schedulerStorePath = status.storePath`
	`75`	`+ self.schedulerStorePath = status.sqlitePath ?? status.storePath`
`76`	`76`	`self.schedulerNextWakeAtMs = status.nextWakeAtMs`
`77`	`77`	`}`
`78`	`78`	`self.jobs = try await GatewayConnection.shared.cronList(includeDisabled: true)`
Original file line number	Diff line number	Diff line change
`@@ -775,6 +775,7 @@ extension GatewayConnection {`
`775`	`775`	`struct CronSchedulerStatus: Decodable {`
`776`	`776`	`let enabled: Bool`
`777`	`777`	`let storePath: String`
	`778`	`+ let sqlitePath: String?`
`778`	`779`	`let jobs: Int`
`779`	`780`	`let nextWakeAtMs: Int?`
`780`	`781`	`}`