class_docstr: ******************************************************************
    The following cases are used to test `create_partition` function 
  ******************************************************************
class_docstr_tok: ["*","*","*","*","*","*","*","*","*","*","*","*","*","*","*","*","*","*","*","*","*","*","*","*","*","*","*","*","*","*","*","*","*","*","*","*","*","*","*","*","*","*","*","*","*","*","*","*","*","*","*","*","*","*","*","*","*","*","*","*","*","*","*","*","*","*","The","following","cases","are","used","to","test","`","create_partition","`","function","*","*","*","*","*","*","*","*","*","*","*","*","*","*","*","*","*","*","*","*","*","*","*","*","*","*","*","*","*","*","*","*","*","*","*","*","*","*","*","*","*","*","*","*","*","*","*","*","*","*","*","*","*","*","*","*","*","*","*","*","*","*","*","*","*","*"]
docstr: target: flushing will recover
  method: call function: create collections, then insert/flushing, restart server and assert row count
  expected: row count equals 0
docstr_tok: ["target",":","flushing","will","recover","method",":","call","function",":","create","collections",",","then","insert\/flushing",",","restart","server","and","assert","row","count","expected",":","row","count","equals","0"]
code: def _test_insert_during_flushing_multi_collections(
      self, connect, args
  ):
      """
      target: flushing will recover
      method: call function: create collections, then insert/flushing, restart server and assert row count
      expected: row count equals 0
      """
      # disable_autoflush()
      collection_num = 2
      collection_list = []
      for i in range(collection_num):
          collection_name = gen_unique_str(uid)
          collection_list.append(collection_name)
          connect.create_collection(collection_name, default_fields)
          ids = connect.bulk_insert(collection_name, big_entities)
      connect.flush(collection_list, _async=True)
      res_count = connect.count_entities(collection_list[-1])
      logging.getLogger().info(res_count)
      if res_count < big_nb:
          # restart server
          assert restart_server(args["service_name"])
          # assert row count again
          new_connect = get_milvus(
              args["ip"], args["port"], handler=args["handler"]
          )
          res_count_2 = new_connect.count_entities(collection_list[-1])
          logging.getLogger().info(res_count_2)
          timeout = 300
          start_time = time.time()
          while time.time() - start_time < timeout:
              count_list = []
              break_flag = True
              for index, name in enumerate(collection_list):
                  tmp_count = new_connect.count_entities(name)
                  count_list.append(tmp_count)
                  logging.getLogger().info(count_list)
                  if tmp_count != big_nb:
                      break_flag = False
                      break
              if break_flag == True:
                  break
              time.sleep(10)
          for name in collection_list:
              assert new_connect.count_entities(name) == big_nb
  
imports: import time
  import random
  import pdb
  import threading
  import logging
  import json
  from multiprocessing import Pool, Process
  import pytest
  from utils.util_pymilvus import get_milvus, restart_server, gen_entities, gen_unique_str, default_nb
  from common.constants import default_fields, default_entities
  from common.common_type import CaseLabel
label_desc: Use image node_id 8 for calling the TestRestartBase obj's underlying member method code with example usage: obj._test_insert_during_flushing_multi_collections(connect, args) without return types