Fix typo in name of private function

This commit is contained in:
Antoine Pitrou 2011-05-03 16:35:43 +02:00
commit 441f935228
1 changed files with 7 additions and 7 deletions

View File

@ -170,7 +170,7 @@ def _add_call_item_to_queue(pending_work_items,
del pending_work_items[work_id]
continue
def _queue_manangement_worker(executor_reference,
def _queue_management_worker(executor_reference,
processes,
pending_work_items,
work_ids_queue,
@ -303,7 +303,7 @@ class ProcessPoolExecutor(_base.Executor):
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,