Function getBatchResults

packages/trigger-sdk/src/v3/shared.ts:583–599

()

          span.setAttribute("messaging.message.id", response.batchId);

          const getBatchResults = async (): Promise<BatchTaskRunExecutionResult> => {
            // We need to check if the results are already available, but only if any of the items options has an idempotency key
            const hasIdempotencyKey = items.some((item) => item.options?.idempotencyKey);

            if (hasIdempotencyKey) {
              const results = await apiClient.getBatchResults(response.batchId);

              if (results) {
                return results;
              }
            }

            return {
              id: response.batchId,
              items: [],
            };
          };

          const existingResults = await getBatchResults();