diff options
| author | Vinay Sajip <vinay_sajip@yahoo.co.uk> | 2024-06-05 06:25:47 (GMT) |
|---|---|---|
| committer | GitHub <noreply@github.com> | 2024-06-05 06:25:47 (GMT) |
| commit | 983efcf15b2503fe0c05d5e03762385967962b33 (patch) | |
| tree | cd2ec5cd1d56cbee9ac2729d40264c88b4f82cd7 /Lib/logging | |
| parent | b6b0dcbfc054f581b6f78602e4c2e9474e3efe21 (diff) | |
| download | cpython-983efcf15b2503fe0c05d5e03762385967962b33.zip cpython-983efcf15b2503fe0c05d5e03762385967962b33.tar.gz cpython-983efcf15b2503fe0c05d5e03762385967962b33.tar.bz2 | |
gh-119819: Update logging configuration to support joinable multiproc… (GH-120090)
gh-119819: Update logging configuration to support joinable multiprocessing manager queues.
Diffstat (limited to 'Lib/logging')
| -rw-r--r-- | Lib/logging/config.py | 4 |
1 files changed, 3 insertions, 1 deletions
diff --git a/Lib/logging/config.py b/Lib/logging/config.py index 0b10bf8..9de84e5 100644 --- a/Lib/logging/config.py +++ b/Lib/logging/config.py @@ -783,8 +783,10 @@ class DictConfigurator(BaseConfigurator): from multiprocessing.queues import Queue as MPQueue from multiprocessing import Manager as MM proxy_queue = MM().Queue() + proxy_joinable_queue = MM().JoinableQueue() qspec = config['queue'] - if not isinstance(qspec, (queue.Queue, MPQueue, type(proxy_queue))): + if not isinstance(qspec, (queue.Queue, MPQueue, + type(proxy_queue), type(proxy_joinable_queue))): if isinstance(qspec, str): q = self.resolve(qspec) if not callable(q): |