pool_handler = Pool(4, count=7, last_refresh=144, mt_size=7)
wallet_handler = <Session(handle=SessionHandle(4), is_transaction=False)>
get_default_trustee = ('V4SGRU86Z58d6TV7PBUe6f', 'GJ1SzoWzavQYfNL9XkaJdrQejfztN4XqdsiV4ct3LXKL')
check_no_failures_fixture = None

    @pytest.mark.asyncio
    async def test_consensus_state_proof_reading(
            pool_handler, wallet_handler, get_default_trustee, check_no_failures_fixture
    ):
        trustee_did, _ = get_default_trustee
        did1, _ = await create_and_store_did(wallet_handler)
        test_nodes = [NodeHost(i) for i in range(1, 8)]
    
        await send_and_get_nym(pool_handler, wallet_handler, trustee_did, did1)
        # Stop all except 1
        for node in test_nodes[1:]:
            node.stop_service()
>       res = await eventually(get_nym, pool_handler, wallet_handler, trustee_did, did1, retry_wait=10, timeout=120)

_          = '4RwB1RNgH5h7QHtVRqW4qgGsFKurDpHsuyT7hUpaEspe'
check_no_failures_fixture = None
did1       = '7Hze2zT8pTt7GvBd5cMu8e'
get_default_trustee = ('V4SGRU86Z58d6TV7PBUe6f', 'GJ1SzoWzavQYfNL9XkaJdrQejfztN4XqdsiV4ct3LXKL')
node       = <system.utils.NodeHost object at 0x7fc0355a4a30>
pool_handler = Pool(4, count=7, last_refresh=144, mt_size=7)
test_nodes = [<system.utils.NodeHost object at 0x7fc0354af760>,
 <system.utils.NodeHost object at 0x7fc03553f220>,
 <system.utils.NodeHost object at 0x7fc03558e910>,
 <system.utils.NodeHost object at 0x7fc03552fc70>,
 <system.utils.NodeHost object at 0x7fc035552c70>,
 <system.utils.NodeHost object at 0x7fc035552be0>,
 <system.utils.NodeHost object at 0x7fc0355a4a30>]
trustee_did = 'V4SGRU86Z58d6TV7PBUe6f'
wallet_handler = <Session(handle=SessionHandle(4), is_transaction=False)>

system/indy-node-tests/test_consensus.py:71: 
_ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ 
system/utils.py:408: in eventually
    raise ex
system/utils.py:387: in eventually
    result = await res
system/utils.py:493: in get_nym
    res = await sign_and_submit_request(pool_handle, wallet_handle, submitter_did, req)
system/utils.py:277: in sign_and_submit_request
    request_result = await pool_handle.submit_request(sreq)
_ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ 

self = Pool(4, count=7, last_refresh=144, mt_size=7), request = Request(freed)

    async def submit_request(self, request: Union[str, bytes, dict, Request]) -> dict:
        """Submit a ledger request.
    
        Args:
            request: May be a prepared `Request` instance, a JSON string or bytes
                instance, or a dict representing a new custom ledger request
    
        Returns:
            A dict representing the decoded JSON response
        """
        if not isinstance(request, Request):
            request = build_custom_request(request)
        if not self.handle:
            raise VdrError(VdrErrorCode.WRAPPER, "pool is closed")
        if not request.handle:
            raise VdrError(VdrErrorCode.WRAPPER, "no request handle")
        fut = bindings.pool_submit_request(self.handle, request.handle)
        request.handle = None  # request has been removed
>       result = await fut
E       indy_vdr.error.VdrError: Pool timeout: Request was interrupted

fut        = <Future finished exception=VdrError('Pool timeout: Request was interrupted')>
request    = Request(freed)
self       = Pool(4, count=7, last_refresh=144, mt_size=7)

/root/.local/share/virtualenvs/indy-test-automation-_hzu7UO4/lib/python3.8/site-packages/indy_vdr/pool.py:115: VdrError