semaphore + react

app.py

@@ -19,6 +19,8 @@ from pytz import timezone
 #
 import asyncio
 
+semaphore = asyncio.Semaphore(1) # for concurrent tasks
+
 zurich_tz = timezone("Europe/Zurich")
 
 def convert_to_timezone(dt, tz):
@@ -52,7 +54,8 @@ async def deepfloydif(ctx, *, prompt: str):
 
         def check_reaction(reaction, user):
             return user == ctx.author and str(reaction.emoji) in ['1️⃣', '2️⃣', '3️⃣', '4️⃣']   
-            
+
+        await ctx.message.add_reaction('👍')
         
         number_of_images = 4
         current_time = int(time.time())
@@ -142,8 +145,10 @@ async def dfif2(ctx, index: int, stage_1_result_path):
         print(f"Error: {e}")
         await ctx.reply('An error occurred while processing stage 2 upscaling. Please try again later.')
 #----------------------------------------------------------------------------------------------------------------------------
-
-
+async def process_dfif2(ctx, index, stage_1_result_path):
+    async with semaphore:
+        await dfif2(ctx, index, stage_1_result_path)
+#----------------------------------------------------------------------------------------------------------------------------