@gen.engine
def Upgrade(callback):
 if options.options.verbose_test_run:
  logging.info('***** NOTE: upgrade is being run in verbose testing mode; run with --verbose_test_run=False once changes have been verified')
  Version.SetMutateItems(False)
 if (options.options.allow_s3_queries is not None):
  logging.info(('Setting allow_s3_queries=%r' % options.options.allow_s3_queries))
  Version.SetAllowS3Queries(options.options.allow_s3_queries)
 OpManager.SetInstance(OpManager(op_map=DB_OPERATION_MAP, client=db_client.DBClient.Instance()))
 tables = [vf_schema.SCHEMA.GetTable(n) for n in options.options.tables]
 if (not tables):
  raise Exception(('The --tables option has not been specified. ' + 'Tables to upgrade must be explicitly listed using this option.'))
 (yield [gen.Task(UpgradeTable, db_client.DBClient.Instance(), table) for table in tables])
 callback()

@ gen . engine def Upgrade ( callback ) : if options . options . verbose_test_run : logging . info ( '***** NOTE: upgrade is being run in verbose testing mode; run with --verbose_test_run=False once changes have been verified' ) Version . SetMutateItems ( False ) if ( options . options . allow_s3_queries is not None ) : logging . info ( ( 'Setting allow_s3_queries=%r' % options . options . allow_s3_queries ) ) Version . SetAllowS3Queries ( options . options . allow_s3_queries ) OpManager . SetInstance ( OpManager ( op_map = DB_OPERATION_MAP , client = db_client . DBClient . Instance ( ) ) ) tables = [ vf_schema . SCHEMA . GetTable ( n ) for n in options . options . tables ] if ( not tables ) : raise Exception ( ( 'The --tables option has not been specified. ' + 'Tables to upgrade must be explicitly listed using this option.' ) ) ( yield [ gen . Task ( UpgradeTable , db_client . DBClient . Instance ( ) , table ) for table in tables ] ) callback ( )
upgrades each table in options .