#NEWLINE# def should_fire( self , watermark , window , context ) : #NEWLINE# #INDENT# ix = context . get_state ( ix . INDEX_TAG ) #NEWLINE# if ( ix < len ( self . triggers ) ) : #NEWLINE# #INDENT# return self . triggers [ ix ] . should_fire ( watermark , window , self . _sub_context ( context , ix ) )