#NEWLINE# def should_fire( self , watermark , window , context ) : #NEWLINE# #INDENT# if self . is_late ( context ) : #NEWLINE# #INDENT# return self . late . should_fire ( watermark , window , NestedContext ( context , 'late' ) ) #NEWLINE# #UNINDENT# else : #NEWLINE# #INDENT# if ( watermark >= window . end ) : #NEWLINE# #INDENT# return True #NEWLINE# #UNINDENT# else : #NEWLINE# #INDENT# if self . early : #NEWLINE# #INDENT# return self . early . should_fire ( self , window , NestedContext ( context , 'early' ) ) #NEWLINE# #UNINDENT# else : #NEWLINE# #INDENT# return False