Function upsert

packages/infra/src/WorkflowEngineCosmos.ts:285–291

(
    body: T
  )

  // Last-writer-wins upsert — used to overwrite a persisted *suspended* activity
  // result once it finally completes (create-only ops can't transition it).
  const upsert = <T extends { readonly id: string; readonly _partitionKey: string }>(
    body: T
  ): Effect.Effect<void> =>
    Effect.gen(function*() {
      const resp = yield* Effect.promise(() => container.items.upsert<T>(body))
      yield* annotateCosmosResponse({ requestCharge: resp.requestCharge, statusCode: resp.statusCode })
    })

  const readPoint = <T extends { id: string }>(id: string, executionId: string) =>
    Effect.promise(() => container.item(id, executionId).read<T>()).pipe(