From f11b94df5270a50cad81897c03d7d96f0e79b6f5 Mon Sep 17 00:00:00 2001
From: andrewso <9V5f1FkzI2LD>
Date: Mon, 12 Oct 2020 17:48:57 +0100
Subject: [PATCH] [12.10.20] Testing

---
 src/tweets/collector.py | 8 +-------
 1 file changed, 1 insertion(+), 7 deletions(-)

diff --git a/src/tweets/collector.py b/src/tweets/collector.py
index e75fea0..5e4ab11 100644
--- a/src/tweets/collector.py
+++ b/src/tweets/collector.py
@@ -69,18 +69,12 @@ class Streamer():
                 stream = Stream(auth=api.auth, listener=listener, tweet_mode='extended')
                 stream.filter(languages=["en"], track=hashtag)
             except IncompleteRead:
-                stream = Stream(auth=api.auth, listener=listener, tweet_mode='extended')
-                stream.filter(languages=["en"], track=hashtag)
                 log("Incomplete Read Error", 'ERR')
                 continue
             except ProtocolError:
-                stream = Stream(auth=api.auth, listener=listener, tweet_mode='extended')
-                stream.filter(languages=["en"], track=hashtag)
                 log("Protocol Error", 'ERR')
                 continue
             except:
-                stream = Stream(auth=api.auth, listener=listener, tweet_mode='extended')
-                stream.filter(languages=["en"], track=hashtag)
                 log("Some other Error", 'ERR')
                 continue
 
@@ -123,7 +117,7 @@ def processTweet(text, type):
     # processStack = dumpStack.copy()
     # dumpStack.clear()
 
-    # log("Processing [{}] Tweets...".format(len(processStack)), 'INFO')
+    log("Processing [{}] Tweet...".format(text), 'INFO')
 
     # if len(processStack) != 0:
     #     for tweet in processStack: