From a1d7833c1db97d7817676541a9de5e867fd24d42 Mon Sep 17 00:00:00 2001
From: Bulat Kurbanov <kurbanovbul@gmail.com>
Date: Tue, 18 Feb 2025 22:10:08 +0100
Subject: [PATCH] Fix

---
 src/modules/stream_notifications/messages_proc.py | 10 ++--------
 1 file changed, 2 insertions(+), 8 deletions(-)

diff --git a/src/modules/stream_notifications/messages_proc.py b/src/modules/stream_notifications/messages_proc.py
index 0be405a..682b4c0 100644
--- a/src/modules/stream_notifications/messages_proc.py
+++ b/src/modules/stream_notifications/messages_proc.py
@@ -93,7 +93,7 @@ class MessageEvent(BaseModel):
 
 
 
-def get_completion(message: str):
+async def get_completion(message: str):
     async with AsyncClient() as client:
         response = await client.post(
             "https://openrouter.ai/api/v1/chat/completions",
@@ -141,13 +141,7 @@ class MessagesProc:
             twitch = await authorize()
 
             try:
-                loop = asyncio.get_event_loop()
-
-                completion = await loop.run_in_executor(
-                    None,
-                    get_completion,
-                    event.message.text
-                )
+                completion = await get_completion(event.message.text)
 
                 if not completion:
                     completion = "Пошел нахуй!"