#NEWLINE# def take_action( self , parsed_args ) : #NEWLINE# #INDENT# self . log . debug ( 'take_action(%s)' , parsed_args ) #NEWLINE# senlin_client = self . app . client_manager . clustering #NEWLINE# columns = [ 'id' , 'timestamp' , 'obj_type' , 'obj_id' , 'obj_name' , 'action' , 'status' , 'status_reason' , 'level' ] #NEWLINE# queries = { #NEWLINE# #INDENT# 'sort' : parsed_args . sort , #NEWLINE# 'limit' : parsed_args . limit , #NEWLINE# 'marker' : parsed_args . marker , #NEWLINE# 'global_project' : parsed_args . global_project , #NEWLINE# #UNINDENT# } #NEWLINE# if parsed_args . filters : #NEWLINE# #INDENT# queries . update ( senlin_utils . format_parameters ( parsed_args . filters ) ) #NEWLINE# #UNINDENT# formatters = { #NEWLINE# #INDENT# #NEWLINE# #UNINDENT# } #NEWLINE# if ( not parsed_args . full_id ) : #NEWLINE# #INDENT# formatters [ 'id' ] = ( lambda x : x [ : 8 ] ) #NEWLINE# formatters [ 'obj_id' ] = ( lambda x : ( x [ : 8 ] if x else '' ) ) #NEWLINE# #UNINDENT# events = senlin_client . events ( ** queries ) #NEWLINE# return ( columns , ( utils . get_item_properties ( e , columns , formatters = formatters ) for e in events ) )