#NEWLINE# def expected_start( self , start_success = None , already_started = None , failed_hosts = None ) : #NEWLINE# #INDENT# return_str = [ ] #NEWLINE# if ( ( not already_started ) and ( not start_success ) and ( not failed_hosts ) ) : #NEWLINE# #INDENT# start_success = self . cluster . all_internal_hosts ( ) #NEWLINE# #UNINDENT# if start_success : #NEWLINE# #INDENT# for host in start_success : #NEWLINE# #INDENT# return_str += [ ( 'Waiting to make sure we can connect to the Presto server on %s, please wait. This check will time out after %d minutes if the server does not respond.' % ( host , ( RETRY_TIMEOUT / 60 ) ) ) , ( 'Server started successfully on: %s' % host ) , ( '\\[%s\\] out: ' % host ) , ( '\\[%s\\] out: Started as .*' % host ) , ( '\\[%s\\] out: Starting presto' % host ) ] #NEWLINE# #UNINDENT# #UNINDENT# if already_started : #NEWLINE# #INDENT# for host in already_started : #NEWLINE# #INDENT# return_str += [ ( 'Waiting to make sure we can connect to the Presto server on %s, please wait. This check will time out after %d minutes if the server does not respond.' % ( self , ( RETRY_TIMEOUT / 60 ) ) ) , ( 'Server started successfully on: %s' % host ) , ( '\\[%s\\] out: ' % host ) , ( '\\[%s\\] out: Already running as .*' % host ) , ( '\\[%s\\] out: Starting presto' % host ) ] #NEWLINE# #UNINDENT# #UNINDENT# if failed_hosts : #NEWLINE# #INDENT# for host in failed_hosts : #NEWLINE# #INDENT# return_str += [ ( '\\[%s\\] out: ' % host ) , ( '\\[%s\\] out: Starting presto' % host ) ] #NEWLINE# #UNINDENT# #UNINDENT# return return_str