calling blocking code in async code

blocking_async.py

import asyncio
import requests
import concurrent
import functools


loop = asyncio.get_event_loop()


def reqq(timeout):
    url = "https://httpbin.org/delay/14"
    r = requests.get(url, timeout=timeout)
    print("\t\n ress")
    print(r)
    return r


async def make():
    timeout = 56
    # running blocking code in a python3 async world:
    # 1. https://docs.python.org/3/library/asyncio-dev.html#running-blocking-code
    # 2. https://docs.python.org/3/library/asyncio-eventloop.html#asyncio.loop.run_in_executor
    with concurrent.futures.ThreadPoolExecutor(
        thread_name_prefix="naz-rabbitmq-thread-pool"
    ) as executor:
        result = await loop.run_in_executor(executor, functools.partial(reqq, timeout=timeout))

    print("resukt")
    print(result)


async def forever():
    while True:
        print("forever1")
        await asyncio.sleep(3, loop=loop)
        print("forever2")


tasks = asyncio.gather(forever(), make())
loop.run_until_complete(tasks)

python blocking_async.py

forever1
forever2
forever1
forever2
forever1
forever2
forever1
	
 ress
<Response [200]>
resukt
<Response [200]>
forever2
forever1
forever2
forever1