From 2a06d431b2e0950a10f66773105003ce3b3e3f62 Mon Sep 17 00:00:00 2001 From: andrewso <9V5f1FkzI2LD> Date: Sat, 10 Oct 2020 22:12:44 +0100 Subject: [PATCH] [10.10.20] Testing --- src/tweets/collector.py | 5 +++++ 1 file changed, 5 insertions(+) diff --git a/src/tweets/collector.py b/src/tweets/collector.py index db64787..e6d9344 100644 --- a/src/tweets/collector.py +++ b/src/tweets/collector.py @@ -82,6 +82,8 @@ class Listener(StreamListener): def on_data(self, data): + log("Received Tweet...") + if (time() - self.start_time) < self.limit: data = json.loads(data) @@ -154,6 +156,7 @@ def timeFunction(): return timeF def createHourJob(): + log("Creating hour job...", 'INFO') schedule.clear("sendToArtemis") ovPos, ovNeu, ovNeg, ovCompound = 0, 0, 0, 0 @@ -181,6 +184,8 @@ def createHourJob(): schedule.every().hour.at(timeF).do(createHourJob).tag("sendToArtemis") + log("Collection will run again at {} every hour".format(time), 'INFO') + def collectorMain(hashtag): log("Starting Tweet Collector", 'INFO')