milvus-io / milvus

        res_count = connect.count_entities(collection)

        assert res_count == 0

    def test_flush_after_delete(self, connect, collection):

        '''

        target: test delete entity

        method: add entities and delete, then flush

        expected: entity deleted and no error raised

        '''

        ids = connect.bulk_insert(collection, default_entities)

        connect.flush([collection])

        delete_ids = [ids[0], ids[-1]]

        status = connect.delete_entity_by_id(collection, delete_ids)

        assert status

        connect.flush([collection])

        res_count = connect.count_entities(collection)

        assert res_count == default_nb - len(delete_ids)

    def test_flush_after_delete_binary(self, connect, binary_collection):

        '''

        res_count = connect.count_entities(collection)

        assert res_count == insert_count - 1

    def test_insert_delete_A(self, connect, collection):

        '''

        target: test delete entity

        method: add entities and delete one in collection, and one not in collection

        expected: no error raised

        '''

        ids = connect.bulk_insert(collection, default_entities)

        connect.flush([collection])

        delete_ids = [ids[0], 1]

        status = connect.delete_entity_by_id(collection, delete_ids)

        assert status

        connect.flush([collection])

        res_count = connect.count_entities(collection)

        assert res_count == default_nb - 1

    def test_insert_delete_B(self, connect, id_collection):

        '''