Fix linter

ozontech · Oct 5, 2023 · ca505b6 · ca505b6
1 parent c27544d
commit ca505b6
Show file tree

Hide file tree

Showing 5 changed files with 6 additions and 6 deletions.
diff --git a/pipeline/pipeline_test.go b/pipeline/pipeline_test.go
@@ -37,7 +37,7 @@ func TestInUnparsableMessages(t *testing.T) {
 	sourceID := pipeline.SourceID(3<<16 + int(10))
 
 	t.Run(name, func(t *testing.T) {
-		pipe := pipeline.New("test_pipeline", pipelineSettings, prometheus.NewRegistry(), zap.NewNop().Sugar())
+		pipe := pipeline.New("test_pipeline", pipelineSettings, prometheus.NewRegistry(), zap.NewNop())
 
 		pipe.SetInput(getFakeInputInfo())
 
@@ -113,7 +113,7 @@ func TestInInvalidMessages(t *testing.T) {
 
 	for _, tCase := range cases {
 		t.Run(tCase.name, func(t *testing.T) {
-			pipe := pipeline.New("test_pipeline", tCase.pipelineSettings, prometheus.NewRegistry(), zap.NewNop().Sugar())
+			pipe := pipeline.New("test_pipeline", tCase.pipelineSettings, prometheus.NewRegistry(), zap.NewNop())
 
 			pipe.SetInput(getFakeInputInfo())
 

diff --git a/pipeline/pipeline_whitebox_test.go b/pipeline/pipeline_whitebox_test.go
@@ -14,7 +14,7 @@ func TestPipeline_streamEvent(t *testing.T) {
 		Capacity: 5,
 		Decoder:  "json",
 	}
-	p := New("test", settings, prometheus.NewRegistry(), zap.NewNop().Sugar())
+	p := New("test", settings, prometheus.NewRegistry(), zap.NewNop())
 
 	streamID := StreamID(123123)
 	procs := int32(7)

diff --git a/plugin/output/file/helpers_test.go b/plugin/output/file/helpers_test.go
@@ -57,7 +57,7 @@ func newPipeline(t *testing.T, configOutput *Config) *pipeline.Pipeline {
 		Decoder:             "json",
 	}
 
-	p := pipeline.New("test_pipeline", settings, prometheus.NewRegistry(), zap.NewNop().Sugar())
+	p := pipeline.New("test_pipeline", settings, prometheus.NewRegistry(), zap.NewNop())
 	p.DisableParallelism()
 	p.EnableEventLog()
 

diff --git a/plugin/output/s3/s3_test.go b/plugin/output/s3/s3_test.go
@@ -405,7 +405,7 @@ func newPipeline(t *testing.T, configOutput *Config, objStoreF objStoreFactory)
 		Decoder:           "json",
 	}
 
-	p := pipeline.New("test_pipeline", settings, prometheus.NewRegistry(), zap.NewNop().Sugar())
+	p := pipeline.New("test_pipeline", settings, prometheus.NewRegistry(), zap.NewNop())
 	p.DisableParallelism()
 	p.EnableEventLog()
 

diff --git a/test/test.go b/test/test.go
@@ -129,7 +129,7 @@ func NewPipeline(actions []*pipeline.ActionPluginStaticInfo, pipelineOpts ...str
 		pName += strconv.Itoa(rand.Int())
 	}
 
-	p := pipeline.New(pName, settings, prometheus.NewRegistry(), zap.NewNop().Sugar())
+	p := pipeline.New(pName, settings, prometheus.NewRegistry(), zap.NewNop())
 	if !parallel {
 		p.DisableParallelism()
 	}