New event loop added for sub thread

main.py

@@ -10,6 +10,7 @@ import requests
 from fastapi import FastAPI
 import uvicorn
 import threading
+import asyncio
 
 app = FastAPI()
 
@@ -271,6 +272,7 @@ def handle_groupreviewrequests_update(event_payload):
         send_notification(title, body, token, author_id, id, "post")
 
 def setup_likes_subscription(SUPABASE_ID, SUPABASE_KEY):
+    asyncio.set_event_loop(asyncio.new_event_loop())
     URL = f"wss://{SUPABASE_ID}.supabase.co/realtime/v1/websocket?apikey={SUPABASE_KEY}&vsn=1.0.0"
 
     with ThreadPoolExecutor(max_workers=10) as executor:
@@ -283,8 +285,7 @@ def setup_likes_subscription(SUPABASE_ID, SUPABASE_KEY):
                 channel_listlikes.join().on(
                     "INSERT", lambda payload: executor.submit(handle_listlikes_update, payload))
 
-                channel_listcomments = s.set_channel(
-                    "realtime:public:listcomments")
+                channel_listcomments = s.set_channel("realtime:public:listcomments")
                 channel_listcomments.join().on(
                     "INSERT", lambda payload: executor.submit(handle_listcomments_update, payload))
 
@@ -292,13 +293,11 @@ def setup_likes_subscription(SUPABASE_ID, SUPABASE_KEY):
                 channel_likes.join().on(
                     "INSERT", lambda payload: executor.submit(handle_likes_update, payload))
 
-                channel_replylikes = s.set_channel(
-                    "realtime:public:replylikes")
+                channel_replylikes = s.set_channel("realtime:public:replylikes")
                 channel_replylikes.join().on(
                     "INSERT", lambda payload: executor.submit(handle_replylikes_update, payload))
 
-                channel_commentlikes = s.set_channel(
-                    "realtime:public:commentlikes")
+                channel_commentlikes = s.set_channel("realtime:public:commentlikes")
                 channel_commentlikes.join().on(
                     "INSERT", lambda payload: executor.submit(handle_commentlikes_update, payload))
 
@@ -314,8 +313,7 @@ def setup_likes_subscription(SUPABASE_ID, SUPABASE_KEY):
                 channel_replies.join().on(
                     "INSERT", lambda payload: executor.submit(handle_reply_update, payload))
 
-                channel_listreplies = s.set_channel(
-                    "realtime:public:listreplies")
+                channel_listreplies = s.set_channel("realtime:public:listreplies")
                 channel_listreplies.join().on(
                     "INSERT", lambda payload: executor.submit(handle_listreply_update, payload))
 
@@ -324,8 +322,8 @@ def setup_likes_subscription(SUPABASE_ID, SUPABASE_KEY):
                     "INSERT", lambda payload: executor.submit(handle_message_update, payload))
 
                 channel_posts = s.set_channel("realtime:public:posts")
-                channel_posts.join().on("INSERT", lambda payload: executor.submit(
-                    handle_groupreviewrequests_update, payload))
+                channel_posts.join().on(
+                    "INSERT", lambda payload: executor.submit(handle_groupreviewrequests_update, payload))
 
                 s.listen()