Fix test insert case

Signed-off-by: BossZou <yinghao.zou@zilliz.com>

internal/util/rocksmq/rocksmq.go

@@ -78,13 +78,6 @@ type RocksMQ struct {
 	channelMu   map[string]*sync.Mutex
 
 	notify map[string][]*Consumer
-	//ctx              context.Context
-	//serverLoopWg     sync.WaitGroup
-	//serverLoopCtx    context.Context
-	//serverLoopCancel func()
-
-	//// tso ticker
-	//tsoTicker *time.Ticker
 }
 
 func NewRocksMQ(name string, idAllocator allocator.GIDAllocator) (*RocksMQ, error) {
@@ -210,7 +203,6 @@ func (rmq *RocksMQ) Produce(channelName string, messages []ProducerMessage) erro
 		return err
 	}
 
-	// TODO(yhz): Here assume allocated id size is equal to message size
 	if UniqueID(msgLen) != idEnd-idStart {
 		return errors.New("Obtained id length is not equal that of message")
 	}

tests/python/test_describe_collection.py

@@ -1,3 +1,4 @@
+import copy
 from .utils import *
 from .constants import *
 
@@ -17,7 +18,7 @@ class TestDescribeCollection:
         expected: returned value is the same
         '''
         collection_name = gen_unique_str(uid)
-        df = default_fields
+        df = copy.deepcopy(default_fields)
         df["fields"].append({"name": "int32", "type": DataType.INT32})
 
         connect.create_collection(collection_name, df)

tests/python/test_insert.py

@@ -831,7 +831,6 @@ class TestInsertMultiCollections:
             count = connect.count_entities(collection_name)
             assert count == default_nb
 
-    @pytest.mark.skip("r0.3-test")
     @pytest.mark.timeout(ADD_TIMEOUT)
     def test_drop_collection_insert_vector_another(self, connect, collection):
         '''