Function readExec

packages/infra/src/WorkflowEngineSqlite.ts:263–274

(executionId: string)

  // --- Core SQL operations ----------------------------------------------

  const readExec = (executionId: string): Effect.Effect<Option.Option<ExecState>> =>
    exec(
      `SELECT * FROM "${execTable}" WHERE execution_id = ?`,
      [executionId]
    )
      .pipe(
        Effect.map((rows) => {
          const r = (rows as ReadonlyArray<ExecRow>)[0]
          return r ? Option.some(parseExec(r)) : Option.none<ExecState>()
        }),
        annotate("readExec", executionId)
      )

  /**
   * OCC-guarded write. Generates a fresh etag on success; returns