From b87a56a51954f470fa864118793cee97c04dca18 Mon Sep 17 00:00:00 2001 From: Antoine Pitrou Date: Tue, 3 May 2011 16:34:42 +0200 Subject: [PATCH] Fix typo in name of private function --- Lib/concurrent/futures/process.py | 14 +++++++------- 1 file changed, 7 insertions(+), 7 deletions(-) diff --git a/Lib/concurrent/futures/process.py b/Lib/concurrent/futures/process.py index 36cd411fc13..ff566d3eb3e 100644 --- a/Lib/concurrent/futures/process.py +++ b/Lib/concurrent/futures/process.py @@ -169,12 +169,12 @@ def _add_call_item_to_queue(pending_work_items, del pending_work_items[work_id] continue -def _queue_manangement_worker(executor_reference, - processes, - pending_work_items, - work_ids_queue, - call_queue, - result_queue): +def _queue_management_worker(executor_reference, + processes, + pending_work_items, + work_ids_queue, + call_queue, + result_queue): """Manages the communication between this process and the worker processes. This function is run in a local thread. @@ -302,7 +302,7 @@ def weakref_cb(_, q=self._result_queue): q.put(None) if self._queue_management_thread is None: self._queue_management_thread = threading.Thread( - target=_queue_manangement_worker, + target=_queue_management_worker, args=(weakref.ref(self, weakref_cb), self._processes, self._pending_work_items,