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

Merge 5de932ba26 into 3a85cb1833

Browse Source
This commit is contained in:
radek-paclt 2026-01-30 16:10:34 +07:00 committed by GitHub
commit 5ce60d2d54
No known key found for this signature in database
GPG Key ID: B5690EEEBB952194
3 changed files with 11 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
src/cron/service/state.ts
View File

@ -10,6 +10,10 @@ export type CronEvent = {
error?: string; error?: string;
summary?: string; summary?: string;
nextRunAtMs?: number; nextRunAtMs?: number;
/** Delivery channel from the job payload (for agentTurn jobs). */
channel?: string;
/** Delivery target from the job payload (for agentTurn jobs). */
to?: string;
}; };
export type Logger = { export type Logger = {

3
src/cron/service/timer.ts
View File

@ -103,6 +103,9 @@ export async function executeJob(
runAtMs: startedAt, runAtMs: startedAt,
durationMs: job.state.lastDurationMs, durationMs: job.state.lastDurationMs,
nextRunAtMs: job.state.nextRunAtMs, nextRunAtMs: job.state.nextRunAtMs,
// Include delivery target from payload for agentTurn jobs
channel: job.payload.kind === "agentTurn" ? job.payload.channel : undefined,
to: job.payload.kind === "agentTurn" ? job.payload.to : undefined,
}); });
if (shouldDelete && state.store) { if (shouldDelete && state.store) {

4
src/gateway/protocol/schema/cron.ts
View File

@ -240,6 +240,10 @@ export const CronRunLogEntrySchema = Type.Object(
runAtMs: Type.Optional(Type.Integer({ minimum: 0 })), runAtMs: Type.Optional(Type.Integer({ minimum: 0 })),
durationMs: Type.Optional(Type.Integer({ minimum: 0 })), durationMs: Type.Optional(Type.Integer({ minimum: 0 })),
nextRunAtMs: Type.Optional(Type.Integer({ minimum: 0 })), nextRunAtMs: Type.Optional(Type.Integer({ minimum: 0 })),
/** Delivery channel from the job payload (for agentTurn jobs). */
channel: Type.Optional(Type.String()),
/** Delivery target from the job payload (for agentTurn jobs). */
to: Type.Optional(Type.String()),
}, },
{ additionalProperties: false }, { additionalProperties: false },
); );