def start_version_async(module, version):
 def _ResultHook(rpc):
  mapped_errors = [modules_service_pb.ModulesServiceError.INVALID_VERSION, modules_service_pb.ModulesServiceError.TRANSIENT_ERROR]
  expected_errors = {modules_service_pb.ModulesServiceError.UNEXPECTED_STATE: ('The specified module: %s, version: %s is already started.' % (module, version))}
  _CheckAsyncResult(rpc, mapped_errors, expected_errors)
 request = modules_service_pb.StartModuleRequest()
 request.set_module(module)
 request.set_version(version)
 response = modules_service_pb.StartModuleResponse()
 return _MakeAsyncCall('StartModule', request, response, _ResultHook)

def start_version_async ( module , version ) : def _ResultHook ( rpc ) : mapped_errors = [ modules_service_pb . ModulesServiceError . INVALID_VERSION , modules_service_pb . ModulesServiceError . TRANSIENT_ERROR ] expected_errors = { modules_service_pb . ModulesServiceError . UNEXPECTED_STATE : ( 'The specified module: %s, version: %s is already started.' % ( module , version ) ) } _CheckAsyncResult ( rpc , mapped_errors , expected_errors ) request = modules_service_pb . StartModuleRequest ( ) request . set_module ( module ) request . set_version ( version ) response = modules_service_pb . StartModuleResponse ( ) return _MakeAsyncCall ( 'StartModule' , request , response , _ResultHook )
returns a userrpc to start all instances for the given module version .