Function readDeferred

packages/infra/src/WorkflowEngineSqlite.ts:408–421

(
    executionId: string,
    name: string
  )

      .pipe(Effect.map((rows) => (rows as ReadonlyArray<unknown>).length > 0))

  const readDeferred = (
    executionId: string,
    name: string
  ): Effect.Effect<Option.Option<string>> =>
    exec(
      `SELECT exit FROM "${deferredTable}" WHERE execution_id = ? AND name = ?`,
      [executionId, name]
    )
      .pipe(
        Effect.map((rows) => {
          const r = (rows as ReadonlyArray<{ exit: string }>)[0]
          return r ? Option.some(r.exit) : Option.none<string>()
        })
      )

  const insertClock = (
    executionId: string,