diff options
author | AUTOMATIC1111 <16777216c@gmail.com> | 2023-07-13 15:21:39 +0300 |
---|---|---|
committer | GitHub <noreply@github.com> | 2023-07-13 15:21:39 +0300 |
commit | b7c5b30f14aadffadd2d35cb3ecb3e91af00581d (patch) | |
tree | 0e51f517bb6ac010c0e3dc5937d112656ec9ee9a /modules/call_queue.py | |
parent | 14501f56aaf3c97fb2c38633350dc747b9651f43 (diff) | |
parent | 262ec8ecdaf10d8fe49d0227e24bd3a1459e87b5 (diff) |
Merge branch 'dev' into master
Diffstat (limited to 'modules/call_queue.py')
-rw-r--r-- | modules/call_queue.py | 5 |
1 files changed, 4 insertions, 1 deletions
diff --git a/modules/call_queue.py b/modules/call_queue.py index 1b5e5273..3b94f8a4 100644 --- a/modules/call_queue.py +++ b/modules/call_queue.py @@ -1,3 +1,4 @@ +from functools import wraps
import html
import threading
import time
@@ -18,6 +19,7 @@ def wrap_queued_call(func): def wrap_gradio_gpu_call(func, extra_outputs=None):
+ @wraps(func)
def f(*args, **kwargs):
# if the first argument is a string that says "task(...)", it is treated as a job id
@@ -28,7 +30,7 @@ def wrap_gradio_gpu_call(func, extra_outputs=None): id_task = None
with queue_lock:
- shared.state.begin()
+ shared.state.begin(job=id_task)
progress.start_task(id_task)
try:
@@ -45,6 +47,7 @@ def wrap_gradio_gpu_call(func, extra_outputs=None): def wrap_gradio_call(func, extra_outputs=None, add_stats=False):
+ @wraps(func)
def f(*args, extra_outputs_array=extra_outputs, **kwargs):
run_memmon = shared.opts.memmon_poll_rate > 0 and not shared.mem_mon.disabled and add_stats
if run_memmon:
|