diff --git a/.idea/workspace.xml b/.idea/workspace.xml
index c08fe12..9934e21 100644
--- a/.idea/workspace.xml
+++ b/.idea/workspace.xml
@@ -4,10 +4,7 @@
-
-
-
-
+
@@ -189,14 +186,6 @@
1706581825121
-
-
- 1712790050272
-
-
-
- 1712790050272
-
1712792878485
@@ -581,11 +570,18 @@
1719171760660
-
+
+
+ 1720964920590
+
+
+
+ 1720964920590
+
+
-
@@ -610,6 +606,7 @@
-
+
+
\ No newline at end of file
diff --git a/bot/reddit/track.py b/bot/reddit/track.py
index 656390a..0475781 100644
--- a/bot/reddit/track.py
+++ b/bot/reddit/track.py
@@ -4,6 +4,7 @@
import re
import orjson
import pendulum as pend
+from loguru import logger
from kafka import KafkaProducer
from os import getenv
@@ -26,6 +27,7 @@
async def post_stream():
+ logger.info("Started Post Stream")
while True:
try:
count = 0
@@ -47,9 +49,11 @@ async def post_stream():
"tags" : tags}}
producer.send(topic="reddit", value=orjson.dumps(json_data), timestamp_ms=int(pend.now(tz=pend.UTC).timestamp()) * 1000)
except Exception as e:
+ logger.error(str(e))
continue
async def comment_stream():
+ logger.info("Started Comment Stream")
while True:
try:
count = 0
@@ -69,6 +73,7 @@ async def comment_stream():
}}
producer.send(topic="reddit", value=orjson.dumps(json_data), timestamp_ms=int(pend.now(tz=pend.UTC).timestamp()) * 1000)
except Exception as e:
+ logger.error(str(e))
continue