ok: true;

ran: true;

jobId: string;

runId?: string;

taskRunId?: string;

startedAt: number;

executionJob: CronJob;

state: CronServiceState,

id: string,

mode?: "due" | "force",

opts?: { runId?: string },

): Promise<PreparedManualRun> {

const preflight = await inspectManualRunPreflight(state, id, mode);

if (!preflight.ok) {

ok: true,

ran: true,

jobId: job.id,

runId: opts?.runId ?? taskRunId,

taskRunId,

startedAt: preflight.now,

executionJob,

const startedAt = prepared.startedAt;

const jobId = prepared.jobId;

const taskRunId = prepared.taskRunId;

const runId = prepared.runId;

let coreResult: Awaited<ReturnType<typeof executeJobCoreWithTimeout>>;

try {

delivery: coreResult.delivery,

sessionId: coreResult.sessionId,

sessionKey: coreResult.sessionKey,

runId,

runAtMs: startedAt,

durationMs: job.state.lastDurationMs,

nextRunAtMs: job.state.nextRunAtMs,

});

}

export async function run(state: CronServiceState, id: string, mode?: "due" | "force") {

const prepared = await prepareManualRun(state, id, mode);

export async function run(

state: CronServiceState,

id: string,

mode?: "due" | "force",

opts?: { runId?: string },

) {

const prepared = await prepareManualRun(state, id, mode, opts);

if (!prepared.ok || !prepared.ran) {

return prepared;

}

void enqueueCommandInLane(

CommandLane.Cron,

async () => {

const result = await run(state, id, mode);

const result = await run(state, id, mode, { runId });

if (result.ok && "ran" in result && !result.ran) {

state.deps.log.info(

{ jobId: id, runId, reason: result.reason },