add damping factor env var

Author: nicktrn

apps/supervisor/src/env.ts

@@ -42,8 +42,9 @@ const Env = z.object({
   TRIGGER_DEQUEUE_SCALING_UP_COOLDOWN_MS: z.coerce.number().int().default(5000), // 5 seconds
   TRIGGER_DEQUEUE_SCALING_DOWN_COOLDOWN_MS: z.coerce.number().int().default(30000), // 30 seconds
   TRIGGER_DEQUEUE_SCALING_TARGET_RATIO: z.coerce.number().default(1.0), // Target ratio of queue items to consumers (1.0 = 1 item per consumer)
-  TRIGGER_DEQUEUE_SCALING_EWMA_ALPHA: z.coerce.number().min(0).max(1).default(0.3), // EWMA smoothing factor (0-1)
+  TRIGGER_DEQUEUE_SCALING_EWMA_ALPHA: z.coerce.number().min(0).max(1).default(0.3), // Smooths queue length measurements (0=historical, 1=current)
   TRIGGER_DEQUEUE_SCALING_BATCH_WINDOW_MS: z.coerce.number().int().positive().default(1000), // Batch window for metrics processing (ms)
+  TRIGGER_DEQUEUE_SCALING_DAMPING_FACTOR: z.coerce.number().min(0).max(1).default(0.7), // Smooths consumer count changes after EWMA (0=no scaling, 1=immediate)
 
   // Optional services
   TRIGGER_WARM_START_URL: z.string().optional(),

apps/supervisor/src/index.ts

@@ -138,6 +138,7 @@ class ManagedSupervisor {
         targetRatio: env.TRIGGER_DEQUEUE_SCALING_TARGET_RATIO,
         ewmaAlpha: env.TRIGGER_DEQUEUE_SCALING_EWMA_ALPHA,
         batchWindowMs: env.TRIGGER_DEQUEUE_SCALING_BATCH_WINDOW_MS,
+        dampingFactor: env.TRIGGER_DEQUEUE_SCALING_DAMPING_FACTOR,
       },
       runNotificationsEnabled: env.TRIGGER_WORKLOAD_API_ENABLED,
       heartbeatIntervalSeconds: env.TRIGGER_WORKER_HEARTBEAT_INTERVAL_SECONDS,

packages/core/src/v3/runEngineWorker/supervisor/consumerPool.ts

@@ -13,7 +13,6 @@ export type QueueConsumerFactory = (opts: RunQueueConsumerOptions) => QueueConsu
 
 export type ScalingOptions = {
   strategy?: ScalingStrategyKind;
-  strategyOptions?: ScalingStrategyOptions;
   minConsumerCount?: number;
   maxConsumerCount?: number;
   scaleUpCooldownMs?: number;
@@ -22,6 +21,7 @@ export type ScalingOptions = {
   ewmaAlpha?: number;
   batchWindowMs?: number;
   disableJitter?: boolean;
+  dampingFactor?: number;
 };
 
 export type ConsumerPoolOptions = {
@@ -99,7 +99,7 @@ export class RunQueueConsumerPool {
     });
 
     const targetRatio = opts.scaling.targetRatio ?? 1.0;
-    const dampingFactor = opts.scaling.strategyOptions?.dampingFactor;
+    const dampingFactor = opts.scaling.dampingFactor;
 
     // Create scaling strategy with metrics processor injected
     this.scalingStrategy = ScalingStrategy.create(opts.scaling.strategy ?? "none", {