capture and pass the planType through to triggering

Author: ericallam

apps/webapp/app/runEngine/services/createBatch.server.ts

@@ -71,6 +71,9 @@ export class CreateBatchService extends WithRunEngine {
             throw entitlementValidation.error;
           }
 
+          // Extract plan type from entitlement validation for billing tracking
+          const planType = entitlementValidation.plan?.type;
+
           // Get batch limits for this organization
           const { config, rateLimiter } = await getBatchLimits(environment.organization);
 
@@ -148,6 +151,7 @@ export class CreateBatchService extends WithRunEngine {
             realtimeStreamsVersion: options.realtimeStreamsVersion,
             idempotencyKey: body.idempotencyKey,
             processingConcurrency: config.processingConcurrency,
+            planType,
           };
 
           await this._engine.initializeBatch(initOptions);

apps/webapp/app/v3/runEngineHandlers.server.ts

@@ -697,6 +697,7 @@ export function setupBatchQueueCallbacks() {
               batchIndex: itemIndex,
               skipChecks: true, // Already validated at batch level
               realtimeStreamsVersion: meta.realtimeStreamsVersion,
+              planType: meta.planType,
             },
             "V2"
           );

internal-packages/run-engine/src/batch-queue/types.ts

@@ -76,6 +76,8 @@ export const BatchMeta = z.object({
   idempotencyKey: z.string().optional(),
   /** Processing concurrency limit for this batch's environment */
   processingConcurrency: z.number().optional(),
+  /** Plan type for billing (e.g., "free", "paid") - used when skipChecks is enabled */
+  planType: z.string().optional(),
 });
 export type BatchMeta = z.infer<typeof BatchMeta>;
 
@@ -161,6 +163,8 @@ export type InitializeBatchOptions = {
   idempotencyKey?: string;
   /** Processing concurrency limit for this batch's environment */
   processingConcurrency?: number;
+  /** Plan type for billing (e.g., "free", "paid") - used when skipChecks is enabled */
+  planType?: string;
 };
 
 /**