def UpdateInstallLogSchema(cursor=None, num_updated=0):
  q = models.InstallLog.all()

  if cursor:
    logging.debug('Continuing with cursor: %s', cursor)
    q.with_cursor(cursor)

  entities = q.fetch(INSTALL_LOG_MAX_FETCH)
  if not entities:
    logging.debug('No remaining entities to convert.')
    return

  entities_to_put = []
  for e in entities:
    e.success = e.IsSuccess()
    e.applesus = getattr(e, 'applesus', False)
    if not getattr(e, 'server_datetime', False):
      e.server_datetime = e.mtime
    entities_to_put.append(e)
  gae_util.BatchDatastoreOp(models.db.put, entities_to_put, 100)

  cursor = q.cursor()
  num_updated += len(entities_to_put)
  logging.info('%s entities converted', num_updated)

  deferred.defer(UpdateInstallLogSchema, cursor=cursor, num_updated=num_updated)
Override this function to enable the connection as part of the server boot.
dataset/ETHPy150Open google/simian/src/simian/mac/admin/maintenance.py/UpdateInstallLogSchema--crossover with--dataset/ETHPy150Open lonelycode/Mojo/Mojo/Backends/base_interface.py/SessionInterface._setup_connection