Skip to content

Commit 121ca8b

Browse files
committed
fix: satisfy cron retry CI checks
1 parent 91bc424 commit 121ca8b

2 files changed

Lines changed: 8 additions & 8 deletions

File tree

src/cron/service/timer.ts

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -1166,7 +1166,7 @@ function isRunnableJob(params: {
11661166
const lastRun = job.state.lastRunAtMs;
11671167
const nextRun = job.state.nextRunAtMs;
11681168
if (isScheduledTerminalOneShotRetry(job, lastRunStatus, lastRun, nextRun)) {
1169-
return nowMs >= nextRun;
1169+
return typeof nextRun === "number" && nowMs >= nextRun;
11701170
}
11711171
return false;
11721172
}

src/gateway/server-cron.test.ts

Lines changed: 7 additions & 7 deletions
Original file line numberDiff line numberDiff line change
@@ -44,23 +44,23 @@ const {
4444
retireSessionMcpRuntimeMock: vi.fn(async () => true),
4545
}));
4646

47-
function enqueueSystemEvent(...args: unknown[]) {
48-
return enqueueSystemEventMock(...args);
47+
function enqueueSystemEvent(text: string, opts?: unknown) {
48+
return enqueueSystemEventMock(text, opts);
4949
}
5050

51-
function enqueueSystemEventEntry(...args: unknown[]) {
52-
const result = enqueueSystemEventMock(...args);
51+
function enqueueSystemEventEntry(text: string, opts?: unknown) {
52+
const result = enqueueSystemEventMock(text, opts);
5353
if (result === false || result === null) {
5454
return null;
5555
}
5656
return {
57-
text: String(args[0] ?? ""),
57+
text,
5858
ts: Date.now(),
5959
};
6060
}
6161

62-
function consumeSelectedSystemEventEntries(...args: unknown[]) {
63-
return consumeSelectedSystemEventEntriesMock(...args);
62+
function consumeSelectedSystemEventEntries(sessionKey: string, entries: readonly unknown[]) {
63+
return consumeSelectedSystemEventEntriesMock(sessionKey, entries);
6464
}
6565

6666
function requestHeartbeat(...args: unknown[]) {

0 commit comments

Comments
 (0)