____________________ test_create_drop_keeper_map_concurrent ____________________
[gw4] linux -- Python 3.8.10 /usr/bin/python3

self = <EventProxy object, typeid 'Event' at 0x7f23986818e0>, methodname = 'set'
args = (), kwds = {}

    def _callmethod(self, methodname, args=(), kwds={}):
        '''
        Try to call a method of the referent and return a copy of the result
        '''
        try:
>           conn = self._tls.connection
E           AttributeError: 'ForkAwareLocal' object has no attribute 'connection'

/usr/lib/python3.8/multiprocessing/managers.py:827: AttributeError

During handling of the above exception, another exception occurred:

started_cluster = <helpers.cluster.ClickHouseCluster object at 0x7f23bc1232b0>

    def test_create_drop_keeper_map_concurrent(started_cluster):
        pool = Pool()
        manager = multiprocessing.Manager()
        stop_event = manager.Event()
        results = []
        for i in range(multiprocessing.cpu_count()):
            sleep(0.2)
            results.append(
                pool.apply_async(
                    create_drop_loop,
                    args=(
                        i,
                        stop_event,
                    ),
                )
            )
    
        sleep(60)
>       stop_event.set()

test_keeper_map/test.py:139: 
_ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ 
/usr/lib/python3.8/multiprocessing/managers.py:1106: in set
    return self._callmethod('set')
/usr/lib/python3.8/multiprocessing/managers.py:831: in _callmethod
    self._connect()
/usr/lib/python3.8/multiprocessing/managers.py:818: in _connect
    conn = self._Client(self._token.address, authkey=self._authkey)
/usr/lib/python3.8/multiprocessing/connection.py:502: in Client
    c = SocketClient(address)
_ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ 

address = '/tmp/pymp-zs6pe87v/listener-afzgl18b'

    def SocketClient(address):
        '''
        Return a connection object connected to the socket given by `address`
        '''
        family = address_type(address)
        with socket.socket( getattr(socket, family) ) as s:
            s.setblocking(True)
>           s.connect(address)
E           ConnectionRefusedError: [Errno 111] Connection refused