def bootstrap_datastore_yaml(wipe=True, **kwargs):
  """Bootstraps arbitrary datastore entities from supplied YAML input.

  Args:
    wipe: bool, whether to wipe all existing datastore models for any model
        contained in the YAML.
    **kwargs: keyword args including a user_email with which to run the
        datastore methods (required for BigQuery streaming).
  """
  with open(
      os.path.join(os.path.dirname(__file__), 'bootstrap.yaml')) as yaml_file:
    datastore_yaml.import_yaml(yaml_file.read(), kwargs['user_email'], wipe)