Как исправить Broken Pipe при использовании многопроцессорных менеджеров Python с использованием baseproxy?

Question

В Разорванный канал при использовании многопроцессорных менеджеров Python (BaseManager / SyncManager) для совместного использования очереди с удаленными компьютерами предлагает добавить следующее: Удалите кэшированное соединение перед повторным подключением.Добавьте код в предложение try-exc в строке, которая вызывает исключение, а затем повторите его.

Если я использую пул и pool.apply_async, как мне это сделать?

from multiprocessing.managers import BaseProxy

...

if address in BaseProxy._address_to_local:
    del BaseProxy._address_to_local[address][0].connection