milvus-io / milvus

        assert len(result) == 0

    # TODO: enable

    @pytest.mark.level(2)

    def _test_list_collections_multiprocessing(self, connect, args):

        '''

        target: test show collections is correct or not with processes

        method: create collection, assert the value returned by list_collections method is equal to 0

        expected: collection_name in show collections

        '''

        collection_name = gen_unique_str("test_collection")

        param = {'collection_name': collection_name,

                 'dimension': dim,

                 'index_file_size': index_file_size,

                 'metric_type': MetricType.L2}

        connect.create_collection(param)

        def showcollections(milvus):

            status, result = milvus.list_collections()

            assert status.OK()

            assert collection_name in result

        process_num = 8

        processes = []

        for i in range(process_num):

            milvus = get_milvus(args["ip"], args["port"], handler=args["handler"])

            p = Process(target=showcollections, args=(milvus,))

            processes.append(p)

            p.start()

        for p in processes:

            p.join()

    """

    ******************************************************************

        assert res.metric_type == MetricType.SUPERSTRUCTURE

    # TODO: enable

    @pytest.mark.level(2)

    def _test_collection_get_collection_info_name_multiprocessing(self, connect, args):

        '''

        target: test describe collection created with multiprocess 

        method: create collection, assert the value returned by describe method

        expected: collection_name equals with the collection name created

        '''

        collection_name = gen_unique_str("test_collection")

        param = {'collection_name': collection_name,

                 'dimension': dim,

                 'index_file_size': index_file_size, 

                 'metric_type': MetricType.L2}

        connect.create_collection(param)

        def describecollection(milvus):

            status, res = milvus.get_collection_info(collection_name)

            assert res.collection_name == collection_name

        process_num = 4

        processes = []

        for i in range(process_num):

            milvus = get_milvus(args["ip"], args["port"], handler=args["handler"])

            p = Process(target=describecollection, args=(milvus,))

            processes.append(p)

            p.start()

        for p in processes:

            p.join()

    # @pytest.mark.level(2)

    # def test_collection_describe_without_connection(self, collection, dis_connect):