From 2a86675b73c3d24fa9091065b3c1a807c67428ff Mon Sep 17 00:00:00 2001 From: Thibault Le Ouay Date: Fri, 23 Oct 2026 14:25:28 +0200 Subject: [PATCH] checker: consume less task at the same time (#2981) --- apps/checker/cmd/server/main.go | 4 ++++ 1 file changed, 4 insertions(+) diff --git a/apps/checker/cmd/server/main.go b/apps/checker/cmd/server/main.go index 0a1cf617f..c0a09d678 100644 --- a/apps/checker/cmd/server/main.go +++ b/apps/checker/cmd/server/main.go @@ -26,6 +26,7 @@ import ( "github.com/openstatushq/openstatus/apps/checker/pkg/tinybird" "github.com/rs/zerolog/log" "go.opentelemetry.io/contrib/bridges/otelslog" + // otelz "go.opentelemetry.io/contrib/bridges/otelzerolog" "go.opentelemetry.io/otel/attribute" otlploghttp "go.opentelemetry.io/otel/exporters/otlp/otlplog/otlploghttp" @@ -348,6 +349,9 @@ func runConsumer(ctx context.Context, h *handlers.Handler, region string) error { Subscription: queue.Subscription(region, false), MaxOutstanding: envInt("PUBSUB_MAX_OUTSTANDING", 500), + // Every held message wakes at the same cronTimestamp: without a cap + // they all dial and handshake at once and inflate each other's timings. + MaxConcurrent: envInt("PUBSUB_MAX_CONCURRENT", 300), }, { Subscription: queue.Subscription(region, true), -- 2.54.0