Multitasking (Multi-Processing) [minor]

ewms_pilot/__init__.py

@@ -1,9 +1,12 @@
 """Init."""
 
 
-from .pilot import consume_and_reply, main
+from .pilot import FileType, consume_and_reply, main
 
-__all__ = ["consume_and_reply"]
+__all__ = [
+    "consume_and_reply",
+    "FileType",
+]
 
 # version is a human-readable version number.
 __version__ = "0.8.0"

ewms_pilot/config.py

@@ -33,6 +33,7 @@ class EnvConfig:
     # meta
     EWMS_PILOT_TASK_TIMEOUT: Optional[int] = None
     EWMS_PILOT_QUARANTINE_TIME: int = 0  # seconds
+    EWMS_PILOT_CONCURRENT_TASKS: int = 1
 
     def __post_init__(self) -> None:
         if timeout := os.getenv("EWMS_PILOT_SUBPROC_TIMEOUT"):