From 9c21460da5507cf6bb856d14947b79cebb7fdaa1 Mon Sep 17 00:00:00 2001
From: Cyril Tovena <cyril.tovena@gmail.com>
Date: Wed, 15 May 2019 16:03:31 -0400
Subject: [PATCH] fix linter

---
 pkg/logentry/pipeline_test.go | 6 +++---
 1 file changed, 3 insertions(+), 3 deletions(-)

diff --git a/pkg/logentry/pipeline_test.go b/pkg/logentry/pipeline_test.go
index 860057e7d0..8d26b97e3a 100644
--- a/pkg/logentry/pipeline_test.go
+++ b/pkg/logentry/pipeline_test.go
@@ -42,7 +42,7 @@ func loadConfig(yml string) PipelineStages {
 
 func TestNewPipeline(t *testing.T) {
 
-	p, err := NewPipeline(util.Logger, loadConfig(testYaml), "test", nil)
+	p, err := NewPipeline(util.Logger, loadConfig(testYaml), "test")
 	if err != nil {
 		panic(err)
 	}
@@ -62,7 +62,7 @@ func TestPipeline_MultiStage(t *testing.T) {
 	if err != nil {
 		panic(err)
 	}
-	p, err := NewPipeline(util.Logger, config["pipeline_stages"].([]interface{}), "test", nil)
+	p, err := NewPipeline(util.Logger, config["pipeline_stages"].([]interface{}), "test")
 	if err != nil {
 		panic(err)
 	}
@@ -138,7 +138,7 @@ func Benchmark(b *testing.B) {
 	}
 	for _, bm := range benchmarks {
 		b.Run(bm.name, func(b *testing.B) {
-			pl, err := NewPipeline(bm.logger, bm.stgs, "test", nil)
+			pl, err := NewPipeline(bm.logger, bm.stgs, "test")
 			if err != nil {
 				panic(err)
 			}