Update app.py

app.py

@@ -1,20 +1,23 @@
-import os
 import asyncio
 from generate_prompts import generate_prompt
 from diffusers import AutoPipelineForText2Image
 from io import BytesIO
 import gradio as gr
-import threading
+import anyio
 
-# Load the model once outside of the function
-print("Loading the model...")
-model = AutoPipelineForText2Image.from_pretrained("stabilityai/sdxl-turbo")
-print("Model loaded successfully.")
+# Asynchronously load the model once outside of the function
+model = None
 
-# Create a thread-local storage object
-thread_local = threading.local()
+async def load_model():
+    global model
+    print("Loading the model...")
+    model = AutoPipelineForText2Image.from_pretrained("stabilityai/sdxl-turbo")
+    print("Model loaded successfully.")
 
-def generate_image(prompt, prompt_name):
+# Run the model loading
+asyncio.run(load_model())
+
+async def generate_image(prompt, prompt_name):
     try:
         print(f"Generating response for {prompt_name} with prompt: {prompt}")
         output = model(prompt=prompt, num_inference_steps=1, guidance_scale=0.0)
@@ -46,13 +49,12 @@ async def queue_api_calls(sentence_mapping, character_dict, selected_style):
     for paragraph_number, sentences in sentence_mapping.items():
         combined_sentence = " ".join(sentences)
         print(f"combined_sentence for paragraph {paragraph_number}: {combined_sentence}")
-        prompt = generate_prompt(combined_sentence, sentence_mapping, character_dict, selected_style)  # Correct prompt generation
+        prompt = generate_prompt(combined_sentence, character_dict, selected_style)  # Correct prompt generation
         prompts.append((paragraph_number, prompt))
         print(f"Generated prompt for paragraph {paragraph_number}: {prompt}")
 
     # Generate images for each prompt in parallel
-    loop = asyncio.get_running_loop()
-    tasks = [loop.run_in_executor(None, generate_image, prompt, f"Prompt {paragraph_number}") for paragraph_number, prompt in prompts]
+    tasks = [generate_image(prompt, f"Prompt {paragraph_number}") for paragraph_number, prompt in prompts]
     print("Tasks created for image generation.")
     responses = await asyncio.gather(*tasks)
     print("Responses received from image generation tasks.")
@@ -63,20 +65,12 @@ async def queue_api_calls(sentence_mapping, character_dict, selected_style):
 
 def process_prompt(sentence_mapping, character_dict, selected_style):
     print(f"process_prompt called with sentence_mapping: {sentence_mapping}, character_dict: {character_dict}, selected_style: {selected_style}")
-    try:
-        # See if there is a loop already running. If there is, reuse it.
-        loop = asyncio.get_running_loop()
-    except RuntimeError:
-        # Create new event loop if one is not running
-        loop = asyncio.new_event_loop()
-        asyncio.set_event_loop(loop)
-    print("Event loop created.")
-
-    # Initialize thread-local variables
-    thread_local.step = 0
-
-    # This sends the prompts to function that sets up the async calls. Once all the calls to the API complete, it returns a list of the gr.Textbox with value= set.
-    cmpt_return = loop.run_until_complete(queue_api_calls(sentence_mapping, character_dict, selected_style))
+    
+    async def run_async():
+        async with anyio.create_task_group() as task_group:
+            return await task_group.start(queue_api_calls, sentence_mapping, character_dict, selected_style)
+    
+    cmpt_return = anyio.run(run_async)
     print(f"process_prompt completed with return value: {cmpt_return}")
     return cmpt_return