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 collection, then indexed, restart server and assert row count
  expected: row count equals nb
docstr_tok: ["target",":","flushing","will","recover","method",":","call","function",":","create","collection",",","then","indexed",",","restart","server","and","assert","row","count","expected",":","row","count","equals","nb"]
code: def _test_during_indexed(self, connect, collection, args):
      """
      target: flushing will recover
      method: call function: create collection, then indexed, restart server and assert row count
      expected: row count equals nb
      """
      # disable_autoflush()
      ids = connect.bulk_insert(collection, big_entities)
      connect.flush([collection])
      connect.create_index(collection, field_name, default_index)
      res_count = connect.count_entities(collection)
      logging.getLogger().info(res_count)
      stats = connect.get_collection_stats(collection)
      # logging.getLogger().info(stats)
      # pdb.set_trace()
      # restart server
      assert restart_server(args["service_name"])
      # assert row count again
      new_connect = get_milvus(
          args["ip"], args["port"], handler=args["handler"]
      )
      assert new_connect.count_entities(collection) == big_nb
      stats = connect.get_collection_stats(collection)
      for file in stats["partitions"][0]["segments"][0]["files"]:
          if file["field"] == field_name and file["name"] != "_raw":
              assert file["data_size"] > 0
              if file["index_type"] != default_index["index_type"]:
                  assert False
              else:
                  assert True
  
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 5 for calling the TestRestartBase obj's underlying member method code with example usage: obj._test_during_indexed(connect, collection, args) without return types