Cron: clean run-log write queue entries (#23968)

* Cron: clean run-log write queue entries

* Changelog: add cron run-log write-queue cleanup note

src/cron/run-log.test.ts

@@ -2,7 +2,12 @@ import fs from "node:fs/promises";
 import os from "node:os";
 import path from "node:path";
 import { describe, expect, it } from "vitest";
-import { appendCronRunLog, readCronRunLogEntries, resolveCronRunLogPath } from "./run-log.js";
+import {
+  appendCronRunLog,
+  getPendingCronRunLogWriteCountForTests,
+  readCronRunLogEntries,
+  resolveCronRunLogPath,
+} from "./run-log.js";
 
 describe("cron run log", () => {
   async function withRunLogDir(prefix: string, run: (dir: string) => Promise<void>) {
@@ -185,4 +190,18 @@ describe("cron run log", () => {
       expect(entries[1]?.usage?.input_tokens).toBeUndefined();
     });
   });
+
+  it("cleans up pending-write bookkeeping after appends complete", async () => {
+    await withRunLogDir("openclaw-cron-log-pending-", async (dir) => {
+      const logPath = path.join(dir, "runs", "job-cleanup.jsonl");
+      await appendCronRunLog(logPath, {
+        ts: 1,
+        jobId: "job-cleanup",
+        action: "finished",
+        status: "ok",
+      });
+
+      expect(getPendingCronRunLogWriteCountForTests()).toBe(0);
+    });
+  });
 });

src/cron/run-log.ts

@@ -27,6 +27,10 @@ export function resolveCronRunLogPath(params: { storePath: string; jobId: string
 
 const writesByPath = new Map<string, Promise<void>>();
 
+export function getPendingCronRunLogWriteCountForTests() {
+  return writesByPath.size;
+}
+
 async function pruneIfNeeded(filePath: string, opts: { maxBytes: number; keepLines: number }) {
   const stat = await fs.stat(filePath).catch(() => null);
   if (!stat || stat.size <= opts.maxBytes) {
@@ -63,7 +67,13 @@ export async function appendCronRunLog(
       });
     });
   writesByPath.set(resolved, next);
-  await next;
+  try {
+    await next;
+  } finally {
+    if (writesByPath.get(resolved) === next) {
+      writesByPath.delete(resolved);
+    }
+  }
 }
 
 export async function readCronRunLogEntries(