387b9c68c8182b82ed1da442892a0aa77372502a,perfkitbenchmarker/linux_benchmarks/cloud_datastore_ycsb_benchmark.py,,_ProcessDeleteKind,#Any#Any#,203

Before Change

  total_count = 0
  while True:
    entities = list(
        client.query(kind=kind).fetch(limit=_CLEANUP_KIND_BATCH_SIZE))
    count_entities = len(entities)
    total_count += count_entities
    if count_entities >= 1:

After Change

      try:
        while entities:
          chunk = entities[:_CLEANUP_KIND_DELETE_BATCH_SIZE]
          entities = entities[_CLEANUP_KIND_DELETE_BATCH_SIZE:]
          client.delete_multi(entity.key for entity in chunk)
        logging.info("Finished %d deletes for %s", count_entities, kind)
      except ValueError as error:
        logging.error("Delete entities for %s failed due to %s", kind, error)

Instances