Multitasking (Multi-Processing) [minor] (#28)

Co-authored-by: github-actions <github-actions@github.com>
Observation-Management-Service · Apr 28, 2023 · 6056971 · 6056971
1 parent fb99127
commit 6056971
Show file tree

Hide file tree

Showing 5 changed files with 596 additions and 262 deletions.
diff --git a/ewms_pilot/__init__.py b/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"

diff --git a/ewms_pilot/config.py b/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"):