diff --git a/src/tweets/collector.py b/src/tweets/collector.py index 3b12353..977e586 100644 --- a/src/tweets/collector.py +++ b/src/tweets/collector.py @@ -89,8 +89,6 @@ class Listener(StreamListener): if (time() - self.start_time) < self.limit: data = json.loads(data) - log(len(dumpStack), 'INFO') - # Check if tweet is a retweet if 'retweeted_status' in data: if 'extended_tweet' in data['retweeted_status']: @@ -109,6 +107,8 @@ class Listener(StreamListener): def processTweet(): + log(len(dumpStack), 'INFO') + processStack = dumpStack.copy() dumpStack.clear()