We don't need these sdk changes anymore because of the different way we are doing failed runs

Author: ericallam

packages/core/src/v3/schemas/api.ts

@@ -409,8 +409,6 @@ export const StreamBatchItemsResponse = z.object({
   itemsAccepted: z.number(),
   /** Number of items that were deduplicated (already enqueued) */
   itemsDeduplicated: z.number(),
-  /** Number of items skipped due to queue size limits */
-  itemsSkipped: z.number().optional(),
   /** Whether the batch was sealed and is ready for processing.
    * If false, the batch needs more items before processing can start.
    * Clients should check this field and retry with missing items if needed. */
@@ -419,9 +417,6 @@ export const StreamBatchItemsResponse = z.object({
   enqueuedCount: z.number().optional(),
   /** Expected total item count (only present when sealed=false to help with retries) */
   expectedCount: z.number().optional(),
-  /** Actual run count after processing (may differ from original if items were skipped).
-   * SDK should use this value for waitForBatch. */
-  runCount: z.number().optional(),
 });
 
 export type StreamBatchItemsResponse = z.infer<typeof StreamBatchItemsResponse>;

packages/trigger-sdk/src/v3/shared.ts

@@ -1571,15 +1571,10 @@ async function executeBatchTwoPhase(
   }
 
   // If the batch was cached (idempotent replay), skip streaming items
-  let actualRunCount = batch.runCount;
   if (!batch.isCached) {
     try {
       // Phase 2: Stream items
-      const streamResult = await apiClient.streamBatchItems(batch.id, items, requestOptions);
-      // Use the runCount from Phase 2 if provided (may differ if items were skipped)
-      if (streamResult.runCount !== undefined) {
-        actualRunCount = streamResult.runCount;
-      }
+      await apiClient.streamBatchItems(batch.id, items, requestOptions);
     } catch (error) {
       // Wrap with context about which phase failed and include batch ID
       throw new BatchTriggerError(
@@ -1591,7 +1586,7 @@ async function executeBatchTwoPhase(
 
   return {
     id: batch.id,
-    runCount: actualRunCount,
+    runCount: batch.runCount,
     publicAccessToken: batch.publicAccessToken,
   };
 }