Function replaceExec

packages/infra/src/WorkflowEngineSqlite.ts:280–320

(
    state: ExecState,
    next: Partial<Omit<ExecState, "executionId" | "etag" | "workflowName" | "payload" | "parent">>
  )

   * `OptimisticConcurrencyException` when no row matches the prior etag.
   */
  const replaceExec = (
    state: ExecState,
    next: Partial<Omit<ExecState, "executionId" | "etag" | "workflowName" | "payload" | "parent">>
  ) =>
    Effect
      .gen(function*() {
        const newEtag = randomUUID()
        const merged = { ...state, ...next, etag: newEtag }
        const rows = yield* exec(
          `UPDATE "${execTable}"
           SET status = ?,
               suspended = ?,
               interrupted = ?,
               completed_result = ?,
               worker = ?,
               lease_expires_at = ?,
               etag = ?
         WHERE execution_id = ? AND etag = ?
         RETURNING etag`,
          [
            merged.status,
            merged.suspended ? 1 : 0,
            merged.interrupted ? 1 : 0,
            merged.completedResult ?? null,
            merged.worker ?? null,
            merged.leaseExpiresAt ?? null,
            newEtag,
            state.executionId,
            state.etag
          ]
        )
        if ((rows as ReadonlyArray<unknown>).length === 0) {
          return yield* new OptimisticConcurrencyException({
            type: "workflow.exec",
            id: state.executionId,
            code: 412
          })
        }
        return merged
      })
      .pipe(annotate("replaceExec", state.executionId))

  const createExec = (initial: ExecState): Effect.Effect<boolean> =>
    exec(