diff --git a/temporal-sdk/src/main/java/io/temporal/internal/worker/PollerOptions.java b/temporal-sdk/src/main/java/io/temporal/internal/worker/PollerOptions.java index 1245907dd..eff0949d8 100644 --- a/temporal-sdk/src/main/java/io/temporal/internal/worker/PollerOptions.java +++ b/temporal-sdk/src/main/java/io/temporal/internal/worker/PollerOptions.java @@ -42,7 +42,7 @@ public static PollerOptions maybeEnrollInPollerAutoscaling( && namespaceCapabilities.isPollerAutoscalingAutoEnroll() && !(options.getPollerBehavior() instanceof PollerBehaviorAutoscaling)) { return PollerOptions.newBuilder(options) - .setPollerBehavior(new PollerBehaviorAutoscaling()) + .setPollerBehavior(new PollerBehaviorAutoscaling(5, 100, 5)) .build(); } return options; diff --git a/temporal-sdk/src/test/java/io/temporal/internal/worker/PollerAutoscalingAutoEnrollTest.java b/temporal-sdk/src/test/java/io/temporal/internal/worker/PollerAutoscalingAutoEnrollTest.java index 5d0df9cc7..21bbdf8bf 100644 --- a/temporal-sdk/src/test/java/io/temporal/internal/worker/PollerAutoscalingAutoEnrollTest.java +++ b/temporal-sdk/src/test/java/io/temporal/internal/worker/PollerAutoscalingAutoEnrollTest.java @@ -66,8 +66,8 @@ public void eligibleDefaultIsEnrolledWhenCapabilityAdvertised() { assertTrue( "defaulted poller type should switch to autoscaling", resolved.getPollerBehavior() instanceof PollerBehaviorAutoscaling); - // The enrolled behavior uses the PollerBehaviorAutoscaling defaults. - assertEquals(new PollerBehaviorAutoscaling(), resolved.getPollerBehavior()); + // The enrolled behavior uses the explicit auto-enroll min/max/initial values. + assertEquals(new PollerBehaviorAutoscaling(5, 100, 5), resolved.getPollerBehavior()); } @Test