fein

main.py

@@ -19,6 +19,7 @@ import queue
 from threads_util.main import Threads
 import asyncpraw
 import instagrapi
+import time
 # print(
 #             os.environ.get("INSTA_USERNAME"), os.environ.get("INSTA_PASSWORD")/
     
@@ -92,10 +93,26 @@ os.makedirs(os.path.dirname(INSTA_COOKIE_PATH), exist_ok=True)
 app = Quart("Auto notifier thingy")
 cache = dc.Cache('/tmp/cache_dir/')
 
-x_client = Client('en-US') 
+x_client = Client('en-US')
 insta_client = instagrapi.Client()
 reddit_client = None
-threads_client = Threads()
+
+# Retry logic for Threads() instantiation
+max_attempts = 5
+for attempt in range(1, max_attempts + 1):
+    try:
+        threads_client = Threads()
+        print("Threads client created successfully.")
+        break  # Exit loop if successful
+    except Exception as e:
+        print(f"Attempt {attempt} failed: {e}")
+        traceback.print_exc()
+        if attempt < max_attempts:
+            print("Retrying in 5 seconds...")
+            time.sleep(5)
+        else:
+            print("Max attempts reached. Raising exception.")
+            raise
 
 async def login_instagram():
     if not os.path.exists(INSTA_COOKIE_PATH):