fork download

import asyncio
 
 
async def worker(request, result):
 
    while True:
 
        data = await request.get()
        print("worker", data)
        await asyncio.sleep(0.1)
        await result.put(str.upper(data))
 
 
async def yoba():
 
    request = asyncio.Queue()
    result = asyncio.Queue()
 
    workers = [loop.create_task(worker(request, result)) for _ in range(5)]
 
    for i in range(15):
 
        await request.put(str.format("yoba {}", i))
 
    while True:
 
        data = await result.get()
        print("yoba", data)
 
 
if __name__ == "__main__":
 
    loop = asyncio.get_event_loop()
    loop.run_until_complete(yoba())
 

Traceback (most recent call last):
  File "/usr/lib/python3.4/py_compile.py", line 124, in compile
    _optimize=optimize)
  File "<frozen importlib._bootstrap>", line 1532, in source_to_code
  File "<frozen importlib._bootstrap>", line 321, in _call_with_frames_removed
  File "./prog.py", line 4
    async def worker(request, result):
            ^
SyntaxError: invalid syntax

During handling of the above exception, another exception occurred:

Traceback (most recent call last):
  File "<string>", line 1, in <module>
  File "/usr/lib/python3.4/py_compile.py", line 128, in compile
    raise py_exc
py_compile.PyCompileError:   File "./prog.py", line 4
    async def worker(request, result):
            ^
SyntaxError: invalid syntax

Standard output is empty