Auto YAPF with Google python style

ionic-bond · Dec 24, 2024 · 8a298d6 · 8a298d6
1 parent 7d5b9c7
commit 8a298d6
Showing 1 changed file with 6 additions and 3 deletions.
diff --git a/stream_translator_gpt/llm_translator.py b/stream_translator_gpt/llm_translator.py
@@ -178,7 +178,7 @@ def _trigger(self, translation_task: TranslationTask):
         thread = threading.Thread(target=self.llm_client.translate, args=(translation_task,))
         thread.daemon = True
         thread.start()
-    
+
     def _retrigger_failed_tasks(self):
         for task in self.processing_queue:
             if task.translation_failed and not _is_task_timeout(task, self.timeout):
@@ -188,7 +188,9 @@ def _retrigger_failed_tasks(self):
 
     def _get_results(self):
         results = []
-        while self.processing_queue and (self.processing_queue[0].translated_text or _is_task_timeout(self.processing_queue[0], self.timeout) or (self.processing_queue[0].translation_failed and not self.retry_if_translation_fails)):
+        while self.processing_queue and (
+                self.processing_queue[0].translated_text or _is_task_timeout(self.processing_queue[0], self.timeout) or
+            (self.processing_queue[0].translation_failed and not self.retry_if_translation_fails)):
             task = self.processing_queue.popleft()
             if not task.translated_text:
                 if _is_task_timeout(task, self.timeout):
@@ -231,7 +233,8 @@ def loop(self, input_queue: queue.SimpleQueue[TranslationTask], output_queue: qu
         current_task = None
         while True:
             if current_task:
-                if (current_task.translated_text or current_task.translation_failed or _is_task_timeout(current_task, self.timeout)):
+                if (current_task.translated_text or current_task.translation_failed or
+                        _is_task_timeout(current_task, self.timeout)):
                     if not current_task.translated_text:
                         if _is_task_timeout(current_task, self.timeout):
                             print('Translation timeout: {}'.format(current_task.transcribed_text))