fix: 保持后端 assignment 可重试

Merge OpenSandbox Runner workload 标记
2026-09-21 08:44:00 +00:00 · 2026-09-21 08:28:32 +00:00
2 changed files with 2 additions and 2 deletions
@@ -167,7 +167,7 @@ func OpenConsumer(ctx context.Context, manager consumerManager, stream, subjectB
 		AckPolicy:     jetstream.AckExplicitPolicy,
 		AckWait:       5 * time.Minute,
 		MaxAckPending: capacity,
-		MaxDeliver:    20,
+		MaxDeliver:    1000,
 	})
 	if err != nil {
 		return nil, fmt.Errorf("open %s assignment consumer: %w", backend, err)
@@ -205,7 +205,7 @@ func TestOpenConsumerUsesIndependentDurablePerBackend(t *testing.T) {
 	if _, err := OpenConsumer(context.Background(), manager, "CI_RUNNER", "ci.assignment", taskassignment.BackendPod, 4); err != nil {
 		t.Fatal(err)
 	}
-	if manager.config.Durable != "pod" || manager.config.FilterSubject != "ci.assignment.pod" || manager.config.AckPolicy != jetstream.AckExplicitPolicy || manager.config.MaxAckPending != 4 {
+	if manager.config.Durable != "pod" || manager.config.FilterSubject != "ci.assignment.pod" || manager.config.AckPolicy != jetstream.AckExplicitPolicy || manager.config.MaxAckPending != 4 || manager.config.MaxDeliver != 1000 {
 		t.Fatalf("config = %#v", manager.config)
 	}
 }
Author	SHA1	Message	Date
panxiao81	906e6a2e18	fix: 保持后端 assignment 可重试 test / shell (pull_request) Failing after 13m28s Details test / python (pull_request) Failing after 13m29s Details test / go (pull_request) Successful in 6m15s Details	2026-09-21 08:44:00 +00:00
panxiao81	ace84373f6	Merge OpenSandbox Runner workload 标记 test / python (push) Successful in 25s Details test / shell (push) Successful in 30s Details test / go (push) Successful in 4m30s Details publish images / publish-images (push) Failing after 13m58s Details	2026-09-21 08:28:32 +00:00