From d90050f81f7bc5ec5c6ec9b26b53e867319164d4 Mon Sep 17 00:00:00 2001 From: Tony Date: Mon, 9 Sep 2019 10:40:41 +0800 Subject: [PATCH] fix import from internal --- pkg/sync/pipeline/pipeline.go | 6 +++--- pkg/sync/pipeline/pipeline_test.go | 1 - 2 files changed, 3 insertions(+), 4 deletions(-) diff --git a/pkg/sync/pipeline/pipeline.go b/pkg/sync/pipeline/pipeline.go index 85fb7f8bb..f1f923dde 100644 --- a/pkg/sync/pipeline/pipeline.go +++ b/pkg/sync/pipeline/pipeline.go @@ -7,9 +7,9 @@ import ( "sync" "time" - "go-common/library/net/metadata" - "go-common/library/stat/metric" - xtime "go-common/library/time" + "github.com/bilibili/kratos/pkg/net/metadata" + "github.com/bilibili/kratos/pkg/stat/metric" + xtime "github.com/bilibili/kratos/pkg/time" ) // ErrFull channel full error diff --git a/pkg/sync/pipeline/pipeline_test.go b/pkg/sync/pipeline/pipeline_test.go index dcfdd8902..79aa27762 100644 --- a/pkg/sync/pipeline/pipeline_test.go +++ b/pkg/sync/pipeline/pipeline_test.go @@ -92,7 +92,6 @@ func TestPipelineSmooth(t *testing.T) { Interval: xtime.Duration(time.Second), Buffer: 100, Worker: 10, - Smooth: true, } type result struct { index int