Update app.py

app.py

@@ -19,7 +19,7 @@ import concurrent.futures
 import multiprocessing
 
 
-semaphore = asyncio.Semaphore(2)
+#semaphore = asyncio.Semaphore(2)
 
 DFIF_TOKEN = os.getenv('HF_TOKEN')
 DISCORD_TOKEN = os.environ.get("GRADIOTEST_TOKEN", None)
@@ -78,14 +78,11 @@ async def generation(ctx, attachment, start_time):
     if attachment:
         style = 'JoJo'
 
-        await semaphore.acquire()
-        try:
-            im = await asyncio.get_running_loop().run_in_executor(None, jojogan.predict, attachment.url, style)
-            semaphore.release()
-        except Exception as e:
-            print('semaphore error')
-            semaphore.release()
-            raise e
+            loop = asyncio.get_running_loop()
+            im = loop.run_in_executor(None, jojogan.predict, attachment.url, style)
+            #im = await asyncio.get_running_loop().run_in_executor(None, jojogan.predict, attachment.url, style)
+            #semaphore.release()
+
         #im = await asyncio.to_thread(jojogan.predict, attachment.url, style)
         #im = jojogan.predict(attachment.url, style)