Remove processor and monitor

Author: stephen-riggs

src/murfey/util/__init__.py

@@ -2,10 +2,7 @@
 
 import logging
 from pathlib import Path
-from queue import Queue
-from threading import Thread
-from typing import Any, Callable, Optional
-from uuid import uuid4
+from typing import Any, Callable
 
 from werkzeug.utils import secure_filename
 
@@ -61,41 +58,6 @@ def posix_path(path: Path) -> str:
     return str(path)
 
 
-class Processor:
-    def __init__(self, name: Optional[str] = None):
-        self._in: Queue = Queue()
-        self._out: Queue = Queue()
-        self._previous: Optional[Processor] = None
-        self.thread: Optional[Thread] = None
-        self.name = name or str(uuid4())[:8]
-
-    def __rshift__(self, other: Processor):
-        self.point_to(other)
-
-    def point_to(self, other: Processor):
-        if isinstance(other, Processor):
-            other._in = self._out
-            other._previous = self
-
-    def process(self, in_thread: bool = False, thread_name: str = "", **kwargs):
-        if in_thread:
-            self.thread = Thread(
-                target=self._process,
-                kwargs=kwargs,
-                name=thread_name or self.name,
-            )
-            self.thread.start()
-        else:
-            self._process(**kwargs)
-
-    def _process(self, **kwargs):
-        pass
-
-    def wait(self):
-        if self.thread:
-            self.thread.join()
-
-
 def safe_run(
     func: Callable,
     args: list | tuple = [],