fix test

Author: pkcll

pkg/loop/logger.go

@@ -195,7 +195,8 @@ func NewOtelLogger(otelLogger otellog.Logger) (logger.Logger, error) {
 	if err != nil {
 		return nil, err
 	}
-	return logger.NewWithCores(primaryCore, otelzap.NewCore(otelLogger)), nil
+	// set debug level from primaryCore to match otelzap.NewCore
+	return logger.NewWithCores(primaryCore, otelzap.NewCore(otelLogger, otelzap.WithLevel(zapcore.DebugLevel))), nil
 }
 
 // onceValue returns a function that invokes f only once and returns the value

pkg/loop/logger_test.go

@@ -5,10 +5,11 @@ import (
 	"sync"
 	"testing"
 
-	"github.com/smartcontractkit/chainlink-common/pkg/logger"
-	"github.com/smartcontractkit/chainlink-common/pkg/logger/otelzap"
 	"github.com/stretchr/testify/assert"
 	sdklog "go.opentelemetry.io/otel/sdk/log"
+
+	"github.com/smartcontractkit/chainlink-common/pkg/logger"
+	"github.com/smartcontractkit/chainlink-common/pkg/logger/otelzap"
 )
 
 func Test_removeArg(t *testing.T) {
@@ -80,6 +81,11 @@ func TestNewOtelLogger(t *testing.T) {
 
 			tt.logFn(lggr)
 
+			// Force flush the logger provider to ensure records are exported
+			if err := lp.ForceFlush(context.Background()); err != nil {
+				t.Fatalf("ForceFlush error: %v", err)
+			}
+
 			if len(exp.records) != 1 {
 				t.Fatalf("expected 1 exported record, got %d", len(exp.records))
 			}