Function readActivity

packages/infra/src/WorkflowEngineSqlite.ts:378–392

(
    executionId: string,
    name: string,
    attempt: number
  )

      .pipe(Effect.asVoid)

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

  const createDeferred = (
    executionId: string,