Update Akeno/utils/base_sqlite.py

Akeno/utils/base_sqlite.py

@@ -24,15 +24,12 @@ async def set_prefix_in_db(user_id: int, prefix: str):
     conn.commit()
 
 async def get_prefix(user_id: int):
-    loop = asyncio.get_running_loop()
-    result = await loop.run_in_executor(None, fetch_prefix_from_db, user_id)
-    return result
+    cursor.execute('SELECT prefix FROM prefixes WHERE user_id=?', (user_id,))
+    result = cursor.fetchone()
 
-def fetch_prefix_from_db(user_id: int):
-    with conn.cursor() as cursor:
-        cursor.execute('SELECT prefix FROM prefixes WHERE user_id=?', (user_id,))
-        result = cursor.fetchone()
-        return result[0] if result else None
+    if result:
+        return result[0]
+    else:
+        return None
 
-async def close_connection():
-    conn.close()
+conn.close()