Basic

Define your tasks:

from arrlio import task

@task
def hello_world():
    print("Hello from Arrlio")

Create application:

from arrlio import App, Config

app = App(Config())

Info

By default local broker and backends will be used

Start consuming tasks and run hello_world task:

async with app:
    await app.consume_tasks()
    await app.send_task(hello_world)

Summary:

main.py
 1
 2
 3
 4
 5
 6
 7
 8
 9
10
11
12
13
14
15
16
17
import asyncio
from arrlio import App, Config, task

@task
def hello_world():
    print("Hello from Arrlio")


async def main():
    app = App(Config())
    async with app:
        await app.consume_tasks()
        await app.send_task(hello_world)


if __name__ == "__main__":
    asyncio.run(main())

More examples can be found in the examples directory.