Function readExec

packages/infra/src/WorkflowEngineCosmos.ts:230–239

(executionId: string)

  // --- Cosmos primitives -------------------------------------------------

  const readExec = (executionId: string) =>
    Effect
      .gen(function*() {
        const resp = yield* Effect.promise(() => container.item(execId, executionId).read<ExecDoc>())
        yield* annotateCosmosResponse({ requestCharge: resp.requestCharge, statusCode: resp.statusCode })
        return Option.fromNullishOr(resp.resource).pipe(
          Option.map((r) => ({ ...r, _etag: resp.etag }))
        )
      })
      .pipe(annotate("readExec", executionId))

  const replaceExec = (doc: ExecDoc) =>
    Effect