Update app.py

app.py

@@ -63,7 +63,7 @@ async def queue_api_calls(sentence_mapping, character_dict, selected_style):
     model_actors = [ModelActor.remote() for _ in range(num_actors)]
     tasks = [model_actors[i % num_actors].generate_image.remote(prompt, f"Prompt {paragraph_number}") for i, (paragraph_number, prompt) in enumerate(prompts)]
 
-    responses = await asyncio.gather(*[asyncio.wrap_future(ray.get(task)) for task in tasks])
+    responses = await asyncio.gather(*[asyncio.wrap_future(asyncio.ensure_future(ray.get(task))) for task in tasks])
     images = {paragraph_number: response for (paragraph_number, _), response in zip(prompts, responses)}
     return images
 
@@ -90,7 +90,7 @@ gradio_interface = gr.Interface(
     fn=process_prompt,
     inputs=[gr.JSON(label="Sentence Mapping"), gr.JSON(label="Character Dict"), gr.Dropdown(["oil painting", "sketch", "watercolor"], label="Selected Style")],
     outputs="json"
-)
+).queue(default_concurrency_limit=20)  # Adjust the concurrency limit as needed
 
 if __name__ == "__main__":
     gradio_interface.launch()