From d7cc2919ee7357b63f1b5b4c41b87b95bd68c74e Mon Sep 17 00:00:00 2001 From: McCloudS <64094529+McCloudS@users.noreply.github.com> Date: Sun, 2 Feb 2025 13:54:32 -0700 Subject: [PATCH] Define the queue properly... --- subgen.py | 6 +++--- 1 file changed, 3 insertions(+), 3 deletions(-) diff --git a/subgen.py b/subgen.py index 61689e4..b1c8d9a 100644 --- a/subgen.py +++ b/subgen.py @@ -125,9 +125,6 @@ in_docker = os.path.exists('/.dockerenv') docker_status = "Docker" if in_docker else "Standalone" last_print_time = None -#start queue -task_queue = DeduplicatedQueue() - def transcription_worker(): while True: task = task_queue.get() @@ -177,6 +174,9 @@ class DeduplicatedQueue(queue.Queue): if self.unfinished_tasks == 0: self._processing.clear() # Reset when all tasks are done +#start queue +task_queue = DeduplicatedQueue() + # Define a filter class to hide common logging we don't want to see class MultiplePatternsFilter(logging.Filter): def filter(self, record):