#NEWLINE# def _call( self , name , * args ) : #NEWLINE# #INDENT# if ( name == 'test_me' ) : #NEWLINE# #INDENT# return args [ 0 ] #NEWLINE# #UNINDENT# instance = GLOBAL_REGISTRY [ self . coord_address_str ] #NEWLINE# method = getattr ( instance , ( 'do_%s' % name ) ) #NEWLINE# try : #NEWLINE# #INDENT# return method ( * args ) #NEWLINE# #UNINDENT# except : #NEWLINE# #INDENT# ( exc_type , exc_instance , _ ) = sys . exc_info ( ) #NEWLINE# remote_exc_type = _get_type_name ( exc_type ) #NEWLINE# if remote_exc_type . startswith ( ACCEPTABLE_EXC_TYPES ) : #NEWLINE# #INDENT# raise #NEWLINE# #UNINDENT# log . error ( __name__ , ( 'Error on %s' % name ) ) #NEWLINE# log . error_exc ( __name__ ) #NEWLINE# remote_exc_args = exc_instance . args #NEWLINE# if ( ( not isinstance ( remote_exc_args , list ) ) and ( not isinstance ( remote_exc_args , tuple ) ) ) : #NEWLINE# #INDENT# remote_exc_args = [ remote_exc_args ] #NEWLINE# #UNINDENT# raise InternalCapturedServerCommunicationError ( remote_exc_type , remote_exc_args )