Function replaceExec

packages/infra/src/WorkflowEngineCosmos.ts:241–261

(doc: ExecDoc)

      .pipe(annotate("readExec", executionId))

  const replaceExec = (doc: ExecDoc) =>
    Effect
      .gen(function*() {
        const resp = yield* Effect.tryPromise(() =>
          container.item(execId, doc._partitionKey).replace<ExecDoc>(doc, {
            accessCondition: { type: "IfMatch", condition: doc._etag ?? "" }
          })
        )
        yield* annotateCosmosResponse({ requestCharge: resp.requestCharge, statusCode: resp.statusCode })
        return { ...doc, _etag: resp.etag }
      })
      .pipe(
        Effect.catch((u) =>
          isOptimisticError(u)
            ? Effect.fail(
              new OptimisticConcurrencyException({ type: "workflow.exec", id: doc._partitionKey, code: 412 })
            )
            : Effect.die(u)
        ),
        annotate("replaceExec", doc._partitionKey)
      )

  // Atomic create-or-noop using a single-op batch — returns true if created.
  const createIfMissing = <T extends { readonly id: string; readonly _partitionKey: string }>(