Function batchDocs

packages/infra/src/ClusterCosmos.ts:430–456

(
    docs: ReadonlyArray<A>,
    operation: (doc: A) => OperationInput,
    fallback: (doc: A) => Effect.Effect<void, unknown, never>
  )

      )

  const batchDocs = <A extends { readonly id: string; readonly _partitionKey: string }>(
    docs: ReadonlyArray<A>,
    operation: (doc: A) => OperationInput,
    fallback: (doc: A) => Effect.Effect<void, unknown, never>
  ): Effect.Effect<void, unknown, never> =>
    Effect.forEach(
      Arr.groupByT(docs, (doc) => doc._partitionKey),
      ([partitionKey, partitionDocs]) =>
        Effect.forEach(
          Arr.chunksOf(partitionDocs, maxCosmosBatchOperations),
          (chunk) => {
            const operations: Array<OperationInput> = chunk.map(operation)
            return Effect
              .tryPromise(() => container.items.batch(operations, partitionKey))
              .pipe(
                Effect.tap(annotateItem),
                Effect.flatMap((resp) => {
                  const failed = resp.result?.find((result) => !isSuccessfulStatus(result.statusCode))
                  return failed === undefined ? Effect.void : Effect.fail(failed.statusCode)
                }),
                Effect.catchIf(() => true, () => Effect.forEach(chunk, fallback, { discard: true }))
              )
          },
          { discard: true }
        ),
      { discard: true }
    )

  const patchDoc = <A extends { readonly id: string; readonly _partitionKey: string }>(
    doc: A,