def sdk_get_reply(looper, sdk_req_resp, timeout=None):
    (req_json, resp_task) = sdk_req_resp
    if (timeout is None):
        timeout = waits.expectedTransactionExecutionTime(7)
    try:
        resp = looper.run(asyncio.wait_for(resp_task, timeout=timeout))
        resp = json.loads(resp)
    except IndyError as e:
        resp = e.error_code
    except TimeoutError as e:
        resp = ErrorCode.PoolLedgerTimeout
    return (req_json, resp)
def sdk_get_reply(looper, sdk_req_resp, timeout=None):
    (req_json, resp_task) = sdk_req_resp
    if (timeout is None):
        timeout = waits.expectedTransactionExecutionTime(7)
    try:
        resp = looper.run(asyncio.wait_for(resp_task, timeout=timeout))
        resp = json.loads(resp)
    except IndyError as e:
        resp = e.error_code
    except TimeoutError as e:
        resp = ErrorCode.PoolLedgerTimeout
    return (req_json, resp)