#NEWLINE# def watch( self ) : #NEWLINE# #INDENT# self . handle_pending ( ) #NEWLINE# previous_step = None #NEWLINE# while ( not self . integration . is_complete ( ) ) : #NEWLINE# #INDENT# self . integration = self . integrations_service . get_item ( self . integration . id ) #NEWLINE# if self . integration . is_complete ( ) : #NEWLINE# #INDENT# break #NEWLINE# #UNINDENT# if ( previous_step != self . integration . step ) : #NEWLINE# #INDENT# previous_step = self . integration . step #NEWLINE# self . progress . increment ( ( '- Performing step: %s' % self . integration . step ) ) #NEWLINE# #UNINDENT# self . progress . step ( ) #NEWLINE# time . sleep ( self . interval ) #NEWLINE# #UNINDENT# self . progress . done ( ) #NEWLINE# print ( '' ) #NEWLINE# return self . print_integration_result ( previous_step . integration )