From 537e302e227d84583e513cd0e3c2223832ec5afc Mon Sep 17 00:00:00 2001 From: Xiangyu Wang Date: Mon, 15 Nov 2021 19:20:34 +0800 Subject: [PATCH] [skip ci]Improve import statements (#11633) Signed-off-by: Xiangyu Wang --- internal/util/flowgraph/flow_graph.go | 3 +-- internal/util/flowgraph/input_node.go | 1 + internal/util/flowgraph/input_node_test.go | 1 + internal/util/flowgraph/message_test.go | 1 + internal/util/flowgraph/node.go | 4 ++-- internal/util/flowgraph/node_test.go | 1 + 6 files changed, 7 insertions(+), 4 deletions(-) diff --git a/internal/util/flowgraph/flow_graph.go b/internal/util/flowgraph/flow_graph.go index 38b8854b15..a77a76ffba 100644 --- a/internal/util/flowgraph/flow_graph.go +++ b/internal/util/flowgraph/flow_graph.go @@ -13,9 +13,8 @@ package flowgraph import ( "context" - "sync" - "errors" + "sync" ) // TimeTickedFlowGraph flowgraph with input from tt msg stream diff --git a/internal/util/flowgraph/input_node.go b/internal/util/flowgraph/input_node.go index c8151a5643..9ecb1778cd 100644 --- a/internal/util/flowgraph/input_node.go +++ b/internal/util/flowgraph/input_node.go @@ -15,6 +15,7 @@ import ( "github.com/milvus-io/milvus/internal/log" "github.com/milvus-io/milvus/internal/msgstream" "github.com/milvus-io/milvus/internal/util/trace" + "github.com/opentracing/opentracing-go" oplog "github.com/opentracing/opentracing-go/log" "go.uber.org/zap" diff --git a/internal/util/flowgraph/input_node_test.go b/internal/util/flowgraph/input_node_test.go index 64d20a512d..74cd25c1f2 100644 --- a/internal/util/flowgraph/input_node_test.go +++ b/internal/util/flowgraph/input_node_test.go @@ -17,6 +17,7 @@ import ( "testing" "github.com/milvus-io/milvus/internal/msgstream" + "github.com/stretchr/testify/assert" ) diff --git a/internal/util/flowgraph/message_test.go b/internal/util/flowgraph/message_test.go index 48c458b542..618f9224c4 100644 --- a/internal/util/flowgraph/message_test.go +++ b/internal/util/flowgraph/message_test.go @@ -16,6 +16,7 @@ import ( "testing" "github.com/milvus-io/milvus/internal/msgstream" + "github.com/stretchr/testify/assert" ) diff --git a/internal/util/flowgraph/node.go b/internal/util/flowgraph/node.go index 70bdaa6032..04d174b69a 100644 --- a/internal/util/flowgraph/node.go +++ b/internal/util/flowgraph/node.go @@ -16,9 +16,9 @@ import ( "sync" "time" - "go.uber.org/zap" - "github.com/milvus-io/milvus/internal/log" + + "go.uber.org/zap" ) // Node is the interface defines the behavior of flowgraph diff --git a/internal/util/flowgraph/node_test.go b/internal/util/flowgraph/node_test.go index d642778e3b..ab48bc1a50 100644 --- a/internal/util/flowgraph/node_test.go +++ b/internal/util/flowgraph/node_test.go @@ -22,6 +22,7 @@ import ( "github.com/milvus-io/milvus/internal/msgstream" "github.com/milvus-io/milvus/internal/proto/commonpb" "github.com/milvus-io/milvus/internal/proto/internalpb" + "github.com/stretchr/testify/assert" )