#NEWLINE# def _get_result_for_month( self , month ) : #NEWLINE# #INDENT# p = df . Pipeline ( 'DirectPipelineRunner' ) #NEWLINE# rows = ( p | df . Create ( 'create' , self . input_data ) ) #NEWLINE# results = filters . filter_cold_days ( rows , month ) #NEWLINE# return results