charliebaby2023 commited on
Commit
3dcbd82
·
verified ·
1 Parent(s): dfb429c

Update handle_models.py

Browse files
Files changed (1) hide show
  1. handle_models.py +14 -7
handle_models.py CHANGED
@@ -38,8 +38,11 @@ async def infer(model_str, prompt, nprompt="", height=0, width=0, steps=0, cfg=0
38
  else:
39
  theSeed = seed
40
  kwargs["seed"] = theSeed
 
 
 
41
  task = asyncio.create_task(asyncio.to_thread(models_load[model_str].fn, prompt=prompt, negative_prompt=nprompt, **kwargs, token=HF_TOKEN))
42
- await asyncio.sleep(0)
43
  try:
44
  result = await asyncio.wait_for(task, timeout=timeout)
45
  except asyncio.TimeoutError as e:
@@ -61,16 +64,20 @@ async def infer(model_str, prompt, nprompt="", height=0, width=0, steps=0, cfg=0
61
  return image
62
  return None
63
 
64
- def gen_fn(model_str, prompt, nprompt="", height=0, width=0, steps=0, cfg=0, seed=-1):
65
  try:
66
  loop = asyncio.new_event_loop()
67
- result = loop.run_until_complete(infer(model_str, prompt, nprompt,
68
- height, width, steps, cfg, seed, inference_timeout))
69
- except (Exception, asyncio.CancelledError) as e:
70
- print(e)
71
- print(f"gen_fn: Task aborted: {model_str}")
 
 
72
  result = None
73
  raise gr.Error(f"Task aborted: {model_str}, Error: {e}")
74
  finally:
75
  loop.close()
76
  return result
 
 
 
38
  else:
39
  theSeed = seed
40
  kwargs["seed"] = theSeed
41
+ print(f"timeout timeout timeout is set to")
42
+ print(f" {timeout}")
43
+ print(f"timeout timeout timeout is set to")
44
  task = asyncio.create_task(asyncio.to_thread(models_load[model_str].fn, prompt=prompt, negative_prompt=nprompt, **kwargs, token=HF_TOKEN))
45
+ await asyncio.sleep(20)
46
  try:
47
  result = await asyncio.wait_for(task, timeout=timeout)
48
  except asyncio.TimeoutError as e:
 
64
  return image
65
  return None
66
 
67
+ def gen_fn(model_str, prompt, nprompt="", height=0, width=0, steps=0, cfg=0, seed=-1, inference_timeout=60):
68
  try:
69
  loop = asyncio.new_event_loop()
70
+ result = loop.run_until_complete(
71
+ infer(model_str, prompt, nprompt, height, width, steps, cfg, seed, inference_timeout))
72
+ #except (Exception, asyncio.CancelledError) as e:
73
+ except Exception as e:
74
+ print(f"{e}")
75
+ print(f"{e}")
76
+ print(f"{e}")
77
  result = None
78
  raise gr.Error(f"Task aborted: {model_str}, Error: {e}")
79
  finally:
80
  loop.close()
81
  return result
82
+
83
+