Add type annotation

newtheatre · Jul 29, 2023 · 43b25aa · 43b25aa
1 parent eee9b92
commit 43b25aa
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/nthp_api/nthp_build/parallel.py b/nthp_api/nthp_build/parallel.py
@@ -28,7 +28,7 @@ def run_cpu_task(task: Callable, error_queue: Queue):
 
 def run_cpu_tasks_in_parallel(tasks: list[Callable]):
     log.info("Running %d CPU tasks in parallel", len(tasks))
-    error_queue = Queue()
+    error_queue: Queue = Queue()
     running_tasks = [
         Process(target=run_cpu_task, args=(task, error_queue)) for task in tasks
     ]