diff --git a/internal/util/rocksmq/rocksmq.go b/internal/util/rocksmq/rocksmq.go index 4515d94689..984f67f161 100644 --- a/internal/util/rocksmq/rocksmq.go +++ b/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") } diff --git a/tests/python/test_describe_collection.py b/tests/python/test_describe_collection.py index c4315691c9..13d50b7a66 100644 --- a/tests/python/test_describe_collection.py +++ b/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) diff --git a/tests/python/test_insert.py b/tests/python/test_insert.py index 357bbd2293..8026a1fa5a 100644 --- a/tests/python/test_insert.py +++ b/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): '''