return "failed";

}

function isTerminalTaskFlowStatus(status: TaskFlowStatus): boolean {

return (

status === "succeeded" ||

status === "blocked" ||

status === "failed" ||

status === "cancelled" ||

status === "lost"

);

}

function resolveTaskMirroredFlowTiming(

task: Pick<TaskRecord, "createdAt" | "lastEventAt" | "endedAt">,

isTerminal: boolean,

): { updatedAt: number; endedAt?: number } {

if (!isTerminal) {

return { updatedAt: task.lastEventAt ?? task.createdAt };

}

const endedAt = task.endedAt ?? task.lastEventAt ?? task.createdAt;

return { updatedAt: endedAt, endedAt };

}

function ensureFlowRegistryReady() {

if (restoreAttempted) {

return;

requesterOrigin?: TaskFlowRecord["requesterOrigin"];

}): TaskFlowRecord {

const terminalFlowStatus = deriveTaskFlowStatusFromTask(params.task);

const isTerminal =

terminalFlowStatus === "succeeded" ||

terminalFlowStatus === "blocked" ||

terminalFlowStatus === "failed" ||

terminalFlowStatus === "cancelled" ||

terminalFlowStatus === "lost";

const endedAt = isTerminal

? (params.task.endedAt ?? params.task.lastEventAt ?? params.task.createdAt)

: undefined;

const timing = resolveTaskMirroredFlowTiming(

params.task,

isTerminalTaskFlowStatus(terminalFlowStatus),

);

return createFlowRecord({

syncMode: "task_mirrored",

ownerKey: params.task.ownerKey,

terminalFlowStatus === "blocked" ? normalizeOptionalString(params.task.taskId) : undefined,

blockedSummary: resolveFlowBlockedSummary(params.task),

createdAt: params.task.createdAt,

updatedAt: params.task.lastEventAt ?? params.task.createdAt,

...(endedAt !== undefined ? { endedAt } : {}),

updatedAt: timing.updatedAt,

...(timing.endedAt !== undefined ? { endedAt: timing.endedAt } : {}),

});

}

return flow;

}

const terminalFlowStatus = deriveTaskFlowStatusFromTask(task);

const isTerminal =

terminalFlowStatus === "succeeded" ||

terminalFlowStatus === "blocked" ||

terminalFlowStatus === "failed" ||

terminalFlowStatus === "cancelled" ||

terminalFlowStatus === "lost";

const isTerminal = isTerminalTaskFlowStatus(terminalFlowStatus);

const timing = resolveTaskMirroredFlowTiming(

{

createdAt: flow.createdAt,

lastEventAt: task.lastEventAt,

endedAt: task.endedAt,

},

isTerminal,

);

return updateFlowRecordByIdUnchecked(flowId, {

status: terminalFlowStatus,

notifyPolicy: task.notifyPolicy,

blockedSummary:

terminalFlowStatus === "blocked" ? (resolveFlowBlockedSummary(task) ?? null) : null,

waitJson: null,

updatedAt: task.lastEventAt ?? Date.now(),

updatedAt: timing.updatedAt,

...(isTerminal

? {

endedAt: task.endedAt ?? task.lastEventAt ?? Date.now(),

endedAt: timing.endedAt ?? timing.updatedAt,

}

: { endedAt: null }),

});