Merge branch 'main' into dominik/eng-9263-utilize-engines-support-for-field-args-on-required-fields-on

Author: dkorittki

router/CHANGELOG.md

@@ -4,6 +4,14 @@ Binaries are attached to the github release otherwise all images can be found [h
 All notable changes to this project will be documented in this file.
 See [Conventional Commits](https://conventionalcommits.org) for commit guidelines.
 
+## [0.301.1](https://github.com/wundergraph/cosmo/compare/router@0.301.0...router@0.301.1) (2026-04-07)
+
+### Bug Fixes
+
+* change failed query to debug instead of warn ([#2745](https://github.com/wundergraph/cosmo/issues/2745)) ([329e5cc](https://github.com/wundergraph/cosmo/commit/329e5cc13168e2aa87aa38bb04bc7fb34092bfae)) (@alepane21)
+* change failed request query parse log to warn instead of error ([#2743](https://github.com/wundergraph/cosmo/issues/2743)) ([09e4653](https://github.com/wundergraph/cosmo/commit/09e4653a6a38136a0ba4870d38c00d253b4b6cac)) (@alepane21)
+* make cache warmer debug logs info logs ([#2746](https://github.com/wundergraph/cosmo/issues/2746)) ([ef1f9cf](https://github.com/wundergraph/cosmo/commit/ef1f9cf48774f975ae5d6519d1bad28c78767211)) (@SkArchon)
+
 # [0.301.0](https://github.com/wundergraph/cosmo/compare/router@0.300.1...router@0.301.0) (2026-04-06)
 
 ### Features

router/core/cache_warmup.go

@@ -62,7 +62,7 @@ func WarmupCaches(ctx context.Context, cfg *CacheWarmupConfig) (err error) {
 	if cfg.Timeout <= 0 {
 		w.timeout = time.Second * 30
 	}
-	w.log.Debug("Warmup started",
+	w.log.Info("Warmup started",
 		zap.Int("workers", cfg.Workers),
 		zap.Int("items_per_second", cfg.ItemsPerSecond),
 		zap.Duration("timeout", cfg.Timeout),
@@ -84,7 +84,7 @@ func WarmupCaches(ctx context.Context, cfg *CacheWarmupConfig) (err error) {
 		)
 		return err
 	}
-	w.log.Debug("Warmup completed",
+	w.log.Info("Warmup completed",
 		zap.Int("processed_items", completed),
 		zap.Duration("duration", time.Since(start)),
 	)
@@ -119,7 +119,7 @@ func (w *cacheWarmup) run(ctx context.Context) (int, error) {
 	}
 
 	if len(items) == 0 {
-		w.log.Debug("No items to process")
+		w.log.Info("No items to process")
 		return 0, nil
 	}
 

router/core/cache_warmup_test.go

@@ -7,8 +7,11 @@ import (
 	"time"
 
 	"github.com/stretchr/testify/assert"
+	"github.com/stretchr/testify/require"
 	nodev1 "github.com/wundergraph/cosmo/router/gen/proto/wg/cosmo/node/v1"
 	"go.uber.org/zap"
+	"go.uber.org/zap/zapcore"
+	"go.uber.org/zap/zaptest/observer"
 )
 
 type CacheWarmupMockSource struct {
@@ -330,4 +333,107 @@ func TestCacheWarmup(t *testing.T) {
 		assert.Len(t, processor.processedItems, 0)
 		processor.mux.Unlock()
 	})
+	t.Run("logs warmup started and completed at info level", func(t *testing.T) {
+		t.Parallel()
+		core, logs := observer.New(zapcore.InfoLevel)
+		logger := zap.New(core)
+		source := &CacheWarmupMockSource{
+			items: []*nodev1.Operation{
+				{
+					Request: &nodev1.OperationRequest{
+						Query: "query { foo }",
+					},
+				},
+			},
+		}
+		processor := &CacheWarmupMockProcessor{
+			mux: sync.Mutex{},
+		}
+		cfg := &CacheWarmupConfig{
+			Log:            logger,
+			Source:         source,
+			Processor:      processor,
+			ItemsPerSecond: 0,
+			Workers:        2,
+			Timeout:        time.Second,
+		}
+		ctx, cancel := context.WithCancel(context.Background())
+		defer cancel()
+		err := WarmupCaches(ctx, cfg)
+		require.NoError(t, err)
+
+		infoLogs := logs.FilterLevelExact(zapcore.InfoLevel)
+		messages := make([]string, infoLogs.Len())
+		for i, entry := range infoLogs.All() {
+			messages[i] = entry.Message
+		}
+		require.Contains(t, messages, "Warmup started")
+		require.Contains(t, messages, "Warmup completed")
+	})
+	t.Run("logs no items to process at info level", func(t *testing.T) {
+		t.Parallel()
+		core, logs := observer.New(zapcore.InfoLevel)
+		logger := zap.New(core)
+		source := &CacheWarmupMockSource{}
+		processor := &CacheWarmupMockProcessor{
+			mux: sync.Mutex{},
+		}
+		cfg := &CacheWarmupConfig{
+			Log:            logger,
+			Source:         source,
+			Processor:      processor,
+			ItemsPerSecond: 0,
+			Workers:        2,
+			Timeout:        time.Second,
+		}
+		ctx, cancel := context.WithCancel(context.Background())
+		defer cancel()
+		err := WarmupCaches(ctx, cfg)
+		require.NoError(t, err)
+
+		infoLogs := logs.FilterLevelExact(zapcore.InfoLevel)
+		messages := make([]string, infoLogs.Len())
+		for i, entry := range infoLogs.All() {
+			messages[i] = entry.Message
+		}
+		require.Contains(t, messages, "No items to process")
+	})
+	t.Run("warmup started and completed not logged at debug level", func(t *testing.T) {
+		t.Parallel()
+		// With a DebugLevel observer, Info messages are captured too,
+		// but the key assertion is that the entries themselves are at InfoLevel, not DebugLevel.
+		core, logs := observer.New(zapcore.DebugLevel)
+		logger := zap.New(core)
+		source := &CacheWarmupMockSource{
+			items: []*nodev1.Operation{
+				{
+					Request: &nodev1.OperationRequest{
+						Query: "query { foo }",
+					},
+				},
+			},
+		}
+		processor := &CacheWarmupMockProcessor{
+			mux: sync.Mutex{},
+		}
+		cfg := &CacheWarmupConfig{
+			Log:            logger,
+			Source:         source,
+			Processor:      processor,
+			ItemsPerSecond: 0,
+			Workers:        2,
+			Timeout:        time.Second,
+		}
+		ctx, cancel := context.WithCancel(context.Background())
+		defer cancel()
+		err := WarmupCaches(ctx, cfg)
+		require.NoError(t, err)
+
+		// Verify that "Warmup started" and "Warmup completed" are logged at Info, not Debug
+		for _, entry := range logs.All() {
+			if entry.Message == "Warmup started" || entry.Message == "Warmup completed" || entry.Message == "No items to process" {
+				require.Equal(t, zapcore.InfoLevel, entry.Level, "expected %q to be logged at Info level", entry.Message)
+			}
+		}
+	})
 }

router/internal/requestlogger/requestlogger.go

@@ -233,7 +233,7 @@ func (al *accessLogger) getRequestFields(r *http.Request, logger *zap.Logger) []
 		if err != nil {
 			// We ignore logging the err since it could leak partial sensitive data
 			// such as %pa from "%password"
-			logger.Warn("Failed to parse query parameters")
+			logger.Debug("Failed to parse query parameters")
 			// Since we wanted to ignore some values but we cant parse it
 			// we default to a safer skip all
 			query = ""

router/package.json

@@ -1,6 +1,6 @@
 {
   "name": "router",
-  "version": "0.301.0",
+  "version": "0.301.1",
   "private": true,
   "description": "The WunderGraph Router",
   "keywords": [