#NEWLINE# @ skip_if_cached #NEWLINE# def run_Flatten( self , transform_node ) : #NEWLINE# #INDENT# flatten_result = list ( itertools . chain . from_iterable ( ( self . _cache . get_pvalue ( flatten_result ) for pc in transform_node . inputs ) ) ) #NEWLINE# self . debug_counters [ 'element_counts' ] [ transform_node . full_label ] += len ( flatten_result ) #NEWLINE# self . _cache . cache_output ( transform_node , flatten_result )