openclaw/crabbox
openclaw/crabbox
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases 9 Wiki Activity

fix(portal): batch external runner writes

Browse Source
This commit is contained in:
Vincent Koc 2026-05-06 03:00:42 -07:00
parent 67ac53cd28
commit f5cdda71c3
No known key found for this signature in database
1 changed files with 4 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
worker/src/fleet.ts
View File

@ -1693,6 +1693,7 @@ export class FleetDurableObject implements DurableObject {
const existing = await this.externalRunnerRecords();
const seenIDs = new Set<string>();
const synced: ExternalRunnerRecord[] = [];
const writes: Promise<void>[] = [];
for (const raw of rawRunners) {
const sanitized = sanitizeExternalRunner(raw, provider, now);
if (!sanitized || seenIDs.has(sanitized.id)) {
@ -1717,7 +1718,7 @@ export class FleetDurableObject implements DurableObject {
updatedAt: nowISO,
};
delete runner.stale;
await this.putExternalRunner(runner);
writes.push(this.putExternalRunner(runner));
synced.push(runner);
}
const stale: ExternalRunnerRecord[] = [];
@ -1737,9 +1738,10 @@ export class FleetDurableObject implements DurableObject {
stale: true,
updatedAt: nowISO,
};
await this.putExternalRunner(next);
writes.push(this.putExternalRunner(next));
stale.push(next);
}
await Promise.all(writes);
return json({ runners: synced, stale });
}