fix: update nats Max messages

Arta Asadi · Arta Asadi · commit 666fadf98ec1 · 2025-04-15T22:19:32.000+02:00
diff --git a/discovery/pkg/nats.go b/discovery/pkg/nats.go
@@ -47,7 +47,7 @@ func NewWorker(
 	if ManualTriggers == "true" {
 		topic = global.JobQueueTopicManuals
 	}
-	if err := jq.Stream(ctx, global.StreamName, " describe job runner queue", []string{topic}, 200000); err != nil {
+	if err := jq.Stream(ctx, global.StreamName, " describe job runner queue", []string{topic}, 5000); err != nil {
 		logger.Error("failed to create stream", zap.Error(err))
 		return nil, err
 	}

Original file line number	Diff line number	Diff line change
`@@ -47,7 +47,7 @@ func NewWorker(`
`47`	`47`	`if ManualTriggers == "true" {`
`48`	`48`	`topic = global.JobQueueTopicManuals`
`49`	`49`	`}`
`50`		`- if err := jq.Stream(ctx, global.StreamName, " describe job runner queue", []string{topic}, 200000); err != nil {`
	`50`	`+ if err := jq.Stream(ctx, global.StreamName, " describe job runner queue", []string{topic}, 5000); err != nil {`
`51`	`51`	`logger.Error("failed to create stream", zap.Error(err))`
`52`	`52`	`return nil, err`
`53`	`53`	`}`