fetcher = ProxyFetcher()

App/Chat/PoeChatrouter.py

@@ -3,12 +3,11 @@ from .utils.PoeBot import SendMessage, GenerateImage
 from .Schemas import BotRequest
 from aiohttp import ClientSession
 from pydantic import BaseModel
-
+import asyncio
 from ballyregan.models import Protocols, Anonymities
 from ballyregan import ProxyFetcher
 
 # Setting the debug mode to True, defaults to False
-fetcher = ProxyFetcher()
 
 
 chat_router = APIRouter(tags=["Chat"])
@@ -22,9 +21,19 @@ class InputData(BaseModel):
 
 async def fetch_predictions(data):
     global proxy
+    proxies = []
     proxy_set = proxy != ""
+    if not asyncio.get_event_loop().is_running():
+        # If not, create a new event loop
+        loop = asyncio.new_event_loop()
+        asyncio.set_event_loop(loop)
+    else:
+        # If an event loop is already running, use the current one
+        loop = asyncio.get_event_loop()
+    fetcher = ProxyFetcher(loop=loop)
     if not proxy_set:
         try:
+
             proxies = fetcher.get(
                 limit=10,
                 protocols=[Protocols.HTTP],