From 7e721172edb1d77b26b707b695e79ca449b96c08 Mon Sep 17 00:00:00 2001 From: "chenghan.ying" Date: Fri, 7 Aug 2026 00:31:27 +0000 Subject: [PATCH] fix(test): set PartitionDiscoveryIntervalMs in the consumer integration subscription Without it the field defaults to 0 and managePartitions panics on time.NewTicker(0), hanging the test until the 300s timeout. #528 added the field and updated the messagequeue integration tests, but missed this hand-built SubscriptionConfig. --- .../submitqueue/core/consumer/consumer_test.go | 15 ++++++++------- 1 file changed, 8 insertions(+), 7 deletions(-) diff --git a/test/integration/submitqueue/core/consumer/consumer_test.go b/test/integration/submitqueue/core/consumer/consumer_test.go index fc558d9f..fd0ed984 100644 --- a/test/integration/submitqueue/core/consumer/consumer_test.go +++ b/test/integration/submitqueue/core/consumer/consumer_test.go @@ -126,13 +126,14 @@ func (s *ConsumerIntegrationSuite) newConsumer(t *testing.T, q extqueue.Queue, t Name: topicName, Queue: q, Subscription: extqueue.SubscriptionConfig{ - SubscriberName: "test-worker", - ConsumerGroup: consumerGroup, - PollIntervalMs: 100, - BatchSize: 10, - VisibilityTimeoutMs: 60000, - LeaseRenewalIntervalMs: 2000, - LeaseDurationMs: 5000, + SubscriberName: "test-worker", + ConsumerGroup: consumerGroup, + PollIntervalMs: 100, + PartitionDiscoveryIntervalMs: 100, + BatchSize: 10, + VisibilityTimeoutMs: 60000, + LeaseRenewalIntervalMs: 2000, + LeaseDurationMs: 5000, Retry: extqueue.RetryConfig{ MaxAttempts: 3, InitialBackoffMs: 1000,