#NEWLINE# def _execute( self , pos_args = None ) : #NEWLINE# #INDENT# filter_tasks = pos_args #NEWLINE# tasks = dict ( [ ( t . name , t ) for t in self . task_list ] ) #NEWLINE# if filter_tasks : #NEWLINE# #INDENT# check_tasks_exist ( tasks , filter_tasks ) #NEWLINE# task_list = [ ] #NEWLINE# for name in filter_tasks : #NEWLINE# #INDENT# task = tasks [ name ] #NEWLINE# task_list . append ( task ) #NEWLINE# task_list . extend ( subtasks_iter ( tasks , task ) ) #NEWLINE# #UNINDENT# #UNINDENT# else : #NEWLINE# #INDENT# task_list = self . task_list #NEWLINE# #UNINDENT# write = self . outstream . write #NEWLINE# for task in task_list : #NEWLINE# #INDENT# values = self . dep_manager . get_values ( task . name ) #NEWLINE# result = self . dep_manager . get_result ( task . name ) #NEWLINE# res = self . dep_manager . get_status ( task , tasks ) #NEWLINE# if ( res . status == 'error' ) : #NEWLINE# #INDENT# write ( 'failed {} ({})\n' . format ( task . name , res . get_error_message ( ) ) ) #NEWLINE# continue #NEWLINE# #UNINDENT# if ( res . status == 'up-to-date' ) : #NEWLINE# #INDENT# write ( 'skip {}\n' . format ( task . name ) ) #NEWLINE# continue #NEWLINE# #UNINDENT# task . values = values #NEWLINE# self . dep_manager . save_success ( task , result_hash = result ) #NEWLINE# write ( 'processed {}\n' . format ( task . name ) ) #NEWLINE# #UNINDENT# self . dep_manager . close ( )