RanM commited on
Commit
30c04e8
·
verified ·
1 Parent(s): 5d9bf5a

Update app.py

Browse files
Files changed (1) hide show
  1. app.py +3 -1
app.py CHANGED
@@ -53,7 +53,9 @@ async def queue_api_calls(sentence_mapping, character_dict, selected_style):
53
 
54
  tasks = [model_actor.generate_image.remote(prompt, f"Prompt {paragraph_number}") for paragraph_number, prompt in prompts]
55
  print("Tasks created for image generation.")
56
- responses = await asyncio.gather(*[ray.get(task) for task in tasks])
 
 
57
  print("Responses received from image generation tasks.")
58
 
59
  images = {paragraph_number: response for (paragraph_number, _), response in zip(prompts, responses)}
 
53
 
54
  tasks = [model_actor.generate_image.remote(prompt, f"Prompt {paragraph_number}") for paragraph_number, prompt in prompts]
55
  print("Tasks created for image generation.")
56
+
57
+ done_tasks, _ = await asyncio.wait([asyncio.create_task(ray.wait([task])) for task in tasks], return_when=asyncio.ALL_COMPLETED)
58
+ responses = [await ray.get(task) for task in done_tasks]
59
  print("Responses received from image generation tasks.")
60
 
61
  images = {paragraph_number: response for (paragraph_number, _), response in zip(prompts, responses)}