def process_tick(self, tup):
curtime = int(time.time())<EOL>window_info = WindowContext(curtime - self.window_duration, curtime)<EOL>self.processWindow(window_info, list(self.current_tuples))<EOL>for tup in self.current_tuples:<EOL><INDENT>self.ack(tup)<EOL><DEDENT>self.current_tuples.clear()<EOL>
Called every window_duration