A library inside the project for working with asynchronous tasks.
Quickstart
Make sure you've got RabbitMQ running, then create a new file called tasks.py in your module:
import async_tasks
@async_tasks.actor
async def add(x, y):
print(x, y)In one terminal, run your workers:
python worker.py -q queue_name
Next, call your tasks:
import asyncio
from your_path import *
async def main():
await add.send(x=1, y=2)
if __name__ == '__main__':
loop = asyncio.get_event_loop()
loop.run_until_complete(main())