Update app.py

app.py

@@ -1,22 +1,45 @@
+import os
 import asyncio
 from generate_prompts import generate_prompt
 from diffusers import AutoPipelineForText2Image
 from io import BytesIO
 import gradio as gr
+import threading
+from diffusers.schedulers import PNDMScheduler
 
-# Asynchronously load the model once outside of the function
-model = None
+# Custom Scheduler with ThreadLocal step index
+class ThreadLocalStepScheduler:
+    def __init__(self, base_scheduler):
+        self.base_scheduler = base_scheduler
+        self._step = threading.local()
 
-async def load_model():
-    global model
-    print("Loading the model...")
-    model = AutoPipelineForText2Image.from_pretrained("stabilityai/sdxl-turbo")
-    print("Model loaded successfully.")
+    def _init_step_index(self):
+        self._step.step = 0
 
-# Run the model loading
-asyncio.run(load_model())
+    @property
+    def step(self):
+        if not hasattr(self._step, 'step'):
+            self._init_step_index()
+        return self._step.step
 
-async def generate_image(prompt, prompt_name):
+    @step.setter
+    def step(self, value):
+        self._step.step = value
+
+    def step_process(self, *args, **kwargs):
+        if not hasattr(self._step, 'step'):
+            self._init_step_index()
+        self._step.step += 1
+        return self.base_scheduler.step(*args, **kwargs)
+
+# Load the model once outside of the function
+print("Loading the model...")
+base_scheduler = PNDMScheduler.from_config("stabilityai/sdxl-turbo")
+custom_scheduler = ThreadLocalStepScheduler(base_scheduler)
+model = AutoPipelineForText2Image.from_pretrained("stabilityai/sdxl-turbo", scheduler=custom_scheduler)
+print("Model loaded successfully.")
+
+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)
@@ -48,12 +71,13 @@ 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
-    tasks = [generate_image(prompt, f"Prompt {paragraph_number}") for paragraph_number, prompt in prompts]
+    loop = asyncio.get_running_loop()
+    tasks = [loop.run_in_executor(None, 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.")
@@ -73,6 +97,9 @@ def process_prompt(sentence_mapping, character_dict, selected_style):
         asyncio.set_event_loop(loop)
     print("Event loop created.")
 
+    # Initialize thread-local variables
+    custom_scheduler._init_step_index()
+
     # 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))
     print(f"process_prompt completed with return value: {cmpt_return}")