Function annotate

packages/infra/src/ClusterCosmos.ts:368–369

(operation: string)

  const container = yield* createContainer(prefix)().pipe(Effect.orDie)
  const containerId = `${prefix}cluster`
  const annotate = (operation: string) =>
    annotateDb({ operation, system: "cosmosdb", collection: containerId, entity: "cluster-message-storage" })

  const readMessage = (id: string, partitionKey: string) =>
    Effect.tryPromise(() => container.item(id, partitionKey).read<MessageDoc>()).pipe(