@gen.engine
def ListAllKeys(store, callback, prefix=None, marker=None, batch_size=1000):
  """List all keys (repeatedly call ListKeys)."""
  # maxkeys=1000 is the S3 ListKeys limit.
  batch_size = min(1000, batch_size)
  keys = []
  done = False
  while not done:
    new_keys = yield gen.Task(store.ListKeys, prefix=prefix, marker=marker, maxkeys=batch_size)
    keys.extend(new_keys)
    if batch_size < len(new_keys):
      break
    marker = new_keys[-1]

  callback(keys)
dataset/ETHPy150Open viewfinderco/viewfinder/backend/storage/store_utils.py/ListAllKeys/swapped operands of `<`