fix(commitments): serialize load-modify-save with in-process queue + cross-process file lock

clawsweeper[bot] · clawsweeper[bot] · commit a349f41ccfe8 · 2026-05-25T05:02:36.000Z
diff --git a/CHANGELOG.md b/CHANGELOG.md
@@ -8,6 +8,7 @@ Docs: https://docs.openclaw.ai
 
 ### Fixes
 
+- Agents/commitments: serialize commitment store load-modify-save writes so concurrent heartbeat and CLI updates no longer lose dismissal, sent, or attempt state. (#81153) Thanks @ai-hpc.
 - Gateway/perf: tighten restart and startup benchmark failure handling so long profiling runs, failed probes, and fresh Linux runners no longer produce false passing or `n/a` results.
 - Checks: keep intentional Knip unused-file findings optional so full CI and sparse proof workspaces stay aligned.
 - Docker: restore writable `~/.config` in runtime images. Fixes #85968. Thanks @hkoessler and @Bartok9.
diff --git a/src/commitments/store.test.ts b/src/commitments/store.test.ts
@@ -235,7 +235,7 @@ describe("commitment store delivery selection", () => {
     expect(expiredCommitments[0]?.status).toBe("expired");
   });
 
-  it("serializes concurrent markCommitmentsStatus on disjoint ids without losing a write (#13)", async () => {
+  it("serializes concurrent markCommitmentsStatus on disjoint ids without losing a write", async () => {
     await useTempStateDir();
     await saveCommitmentStore(undefined, {
       version: 1,
@@ -256,7 +256,7 @@ describe("commitment store delivery selection", () => {
     expect(byId.cm_raceB).toBe("dismissed");
   });
 
-  it("serializes concurrent markCommitmentsAttempted bumps without losing the counter (#13)", async () => {
+  it("serializes concurrent markCommitmentsAttempted bumps without losing the counter", async () => {
     await useTempStateDir();
     await saveCommitmentStore(undefined, {
       version: 1,
@@ -273,7 +273,7 @@ describe("commitment store delivery selection", () => {
     expect(after.commitments[0]?.attempts).toBe(5);
   });
 
-  it("serializes a markCommitmentsStatus dismiss against a concurrent attempted bump (#13)", async () => {
+  it("serializes a markCommitmentsStatus dismiss against a concurrent attempted bump", async () => {
     await useTempStateDir();
     await saveCommitmentStore(undefined, {
       version: 1,
