From 8cad048cb80e7f94188ad9cd8f3bb605923b6996 Mon Sep 17 00:00:00 2001 From: Ratnadeep Debnath Date: Fri, 24 Jun 2016 10:04:48 +0530 Subject: [PATCH] Fixed out of place debuggers in publisher. --- ircb/publishers/__init__.py | 9 ++++++--- 1 file changed, 6 insertions(+), 3 deletions(-) diff --git a/ircb/publishers/__init__.py b/ircb/publishers/__init__.py index c1b6aa3..c9099b0 100644 --- a/ircb/publishers/__init__.py +++ b/ircb/publishers/__init__.py @@ -83,15 +83,18 @@ def handle_create(self, data): Check if an insert operation in message_logs table affects our results. If yes, append it to results. """ + skip = False if self.skip(data): - return + skip = skip or True if self.results and data['timestamp'] < self.index[ self.results[-1]]['timestamp']: - return + skip = skip or True if not self.fetched: + skip = skip or True + if skip: + logger.debug('skip created data', data) return - logger.debug('skip created data', data) self.index[data['id']] = data self.results.append(data['id']) logger.debug('updated results: %s, %s', self.results, self.index)