Skip to content

Commit 970ff7c

Browse files
committed
restore get_current_queue method
1 parent 30aeca6 commit 970ff7c

File tree

1 file changed

+8
-0
lines changed

1 file changed

+8
-0
lines changed

execution.py

Lines changed: 8 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -953,6 +953,14 @@ def task_done(self, item_id, history_result,
953953
self.history[prompt[1]].update(history_result)
954954
self.server.queue_updated()
955955

956+
# Note: slow
957+
def get_current_queue(self):
958+
with self.mutex:
959+
out = []
960+
for x in self.currently_running.values():
961+
out += [x]
962+
return (out, copy.deepcopy(self.queue))
963+
956964
# read-safe as long as queue items are immutable
957965
def get_current_queue_volatile(self):
958966
with self.mutex:

0 commit comments

Comments
 (0)