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

Update app.py

Browse files
Files changed (1) hide show
  1. app.py +2 -2
app.py CHANGED
@@ -54,8 +54,8 @@ async def queue_api_calls(sentence_mapping, character_dict, selected_style):
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)}
 
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
+ # Use asyncio to gather the results asynchronously
58
+ responses = await asyncio.gather(*[ray.get(task) for task in tasks])
59
  print("Responses received from image generation tasks.")
60
 
61
  images = {paragraph_number: response for (paragraph_number, _), response in zip(prompts, responses)}