pipeline/__init__.py

@@ -1,6 +1,5 @@
 import logging
 import logging.handlers
-import multiprocessing as mp
 import os
 import shutil
 

pipeline/handlers/handler.py

@@ -1,4 +1,3 @@
-import logging
 
 from abc import ABCMeta, abstractmethod
 from pathlib import Path

pipeline/handlers/metadata.py

@@ -1,5 +1,4 @@
 from .handler import Handler
-from ..exceptions import ValidationException
 
 
 @Handler.register

pipeline/handlers/poster.py

@@ -79,7 +79,7 @@ class PosterHandler(Handler):
         super()._validate(jobspec, existing_package)
         if uploaded:
             if 'upload_dir' not in jobspec:
-                raise ValidationException(f"upload_dir missing")
+                raise ValidationException("upload_dir missing")
         for name, poster in uploaded.items():
             if not path.isfile(path.join(jobspec['upload_dir'],
                                          poster)):

pipeline/handlers/slides.py

@@ -1,5 +1,4 @@
 from os import path, rename
-from shutil import rmtree
 
 import ffmpeg
 

pipeline/handlers/subtitles_import.py

@@ -1,4 +1,3 @@
-import logging
 
 from pathlib import Path
 

pipeline/handlers/subtitles_whisper_hack.py

@@ -6,12 +6,10 @@ from multiprocessing import Process, Queue
 from pathlib import Path
 from queue import Empty
 from time import sleep
-from threading import Event
 
 from .handler import Handler
-from ..exceptions import ConfigurationException, ValidationException
+from ..exceptions import ValidationException
 
-import torch
 import whisper
 import whisper.utils
 
@@ -58,7 +56,7 @@ def _whisper_processor(inqueue,
             if language is None:
                 out_language = result['language']
                 logger.info(
-                    f"Detected language '%s' in %s.", out_language, inpath)
+                    "Detected language '%s' in %s.", out_language, inpath)
             else:
                 out_language = language
 

pipeline/handlers/subtitles_whisper_serial.py

@@ -5,7 +5,6 @@ from multiprocessing import Process, Queue
 from pathlib import Path
 from queue import Empty
 from time import sleep
-from threading import Event
 
 from .handler import Handler
 from ..exceptions import ConfigurationException, ValidationException

pipeline/ldap.py

@@ -1,5 +1,4 @@
 from ldap3 import Connection, ObjectDef, Reader, Server
-from ldap3.core.exceptions import LDAPSocketSendError
 
 class Ldap:
     def __init__(self, conf):

pipeline/notifier.py

@@ -1,5 +1,4 @@
 import json
-import logging
 
 from dataclasses import asdict, dataclass
 from pprint import pformat

pipeline/package.py

@@ -2,7 +2,7 @@ import json
 
 from copy import deepcopy
 from os import mkdir, path, rename, remove
-from shutil import copy, copytree
+from shutil import copytree
 
 import ffmpeg
 

pipeline/preprocessors/cattura.py

@@ -110,4 +110,4 @@ class CatturaProcessor(Preprocessor):
         for key in data.keys():
             if key.startswith('mediapackage:'):
                 return data[key]
-        raise KeyError(f"no 'mediapackage' key in job specification")
+        raise KeyError("no 'mediapackage' key in job specification")

pipeline/preprocessors/preprocessor.py

@@ -1,5 +1,4 @@
 from abc import ABCMeta, abstractmethod
-from os import mkdir, path
 
 from ..queuethread import QueueThread
 

pipeline/workthread.py

@@ -1,4 +1,3 @@
-import logging
 import multiprocessing as mp
 
 from collections import deque
@@ -6,7 +5,7 @@ from collections.abc import Iterable
 from dataclasses import dataclass
 from pprint import pformat
 from threading import Event
-from time import sleep, strftime
+from time import sleep
 from typing import Callable
 
 from .queuethread import QueueThread

play-daemon.py

@@ -5,7 +5,6 @@ import sys
 
 from configparser import ConfigParser
 from os import path
-from time import sleep
 
 from pipeline import Pipeline
 

test.py

@@ -272,7 +272,7 @@ class PipelineTest(DaemonTest):
                     print("¤ Contents of invalid notification file ¤")
                     print(f.read())
                     print("¤ End invalid notification file contents ¤")
-                    self.fail(f"Invalid JSON in result file.")
+                    self.fail("Invalid JSON in result file.")
 
             # Validate that this is the correct resultfile
             self.assertEqual(jobid, result['jobid'])