Hello I have cloned this repo, created venv with pyhton 3.9 and tried to run the above file, but it crashed... with the following error. Not always, but in 20-30% cases

`RuntimeError: Task <Task pending name='Task-3' coro=<process_data() running at /async-techniques-python-course/src/04-asyncio/producer_consumer/prod_async/async_program.py:40> cb=[_gather.._done_callback() at .pyenv/versions/3.9.13/lib/python3.9/asyncio/tasks.py:767]> got Future attached to a different loop
Task was destroyed but it is pending!
task: <Task pending name='Task-1' coro=<generate_data() running at /async-techniques-python-course/src/04-asyncio/producer_consumer/prod_async/async_program.py:34> wait_for=<Future pending cb=[<TaskWakeupMethWrapper object at 0x7f4babcf3400>()]> cb=[_gather.._done_callback() at .pyenv/versions/3.9.13/lib/python3.9/asyncio/tasks.py:767]>
Task was destroyed but it is pending!
task: <Task pending name='Task-2' coro=<generate_data() running at /async-techniques-python-course/src/04-asyncio/producer_consumer/prod_async/async_program.py:34> wait_for=<Future pending cb=[<TaskWakeupMethWrapper object at 0x7f4babcf33a0>()]> cb=[_gather.._done_callback() at .pyenv/versions/3.9.13/lib/python3.9/asyncio/tasks.py:767]>

Process finished with exit code 1`

Looks like there is a problem with how queues are arranged...