fixup 39f7625: get queue type from mp.get_ctxt

OCR-D · Feb 11, 2025 · 7456714 · 7456714
1 parent 39f7625
commit 7456714
Show file tree

Hide file tree

Showing 2 changed files with 2 additions and 3 deletions.
diff --git a/repo/spec b/repo/spec
diff --git a/src/ocrd/processor/base.py b/src/ocrd/processor/base.py
@@ -29,7 +29,6 @@
 # this is where the fixes came from:
 from loky import Future, ProcessPoolExecutor
 import multiprocessing as mp
-from queue import Queue # mp.queues.Queue does not behave with logging.handlers.QueueListener
 from threading import Timer
 from _thread import interrupt_main
 
@@ -519,7 +518,7 @@ def process_workspace(self, workspace: Workspace) -> None:
 
                 if max_workers > 1:
                     executor_cls = ProcessPoolExecutor
-                    log_queue = Queue()
+                    log_queue = mp.get_context('fork').Queue()
                 else:
                     executor_cls = DummyExecutor
                     log_queue = None
+2 −0		.gitignore
+56 −0		CHANGELOG.md
+8 −8		Makefile
+1 −1		README.md
+ −		assets/request-processing.jpg
+ −		assets/web-api-distributed-queue.jpg
+ −		assets/web-api-distributed.jpg
+1 −1		bagit-profile.json
+6 −1		cli.md
+167 −163		decisions.md
+1 −1		glossary.md
+2 −2		nextflow.md
+548 −0		ocrd_eval.md
+102 −0		ocrd_eval.sample.json
+1 −0		ocrd_eval.schema.json
+217 −0		ocrd_eval.schema.yml
+6 −5		ocrd_tool.md
+1 −1		ocrd_tool.schema.json
+46 −12		ocrd_tool.schema.yml
+332 −206		openapi.yml
+1 −1		page.md
+4 −2		scripts/yaml-to-json.py
+397 −0		web_api.md
+144 −0		web_api/config.schema.yml
+66 −0		web_api/processing-message.schema.yml
+31 −0		web_api/result-message.schema.yml