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