colas 0.1.2

Modern task queue framework

Colas

A modern, minimalist task queue framework.

• fully async
• supports database backends for queues
• no crazy inventions for task discovery, logging or configuration

Supported backends:

• Sqlite
• Postgres

Author: Igor Prochazka (@projazzka)

Installation

pip install colas

Usage

# tasks.py

from colas import Colas

app = Colas("sqlite://./colas.db")

@app.task
async def multiply(a: int, b: int) -> int:
    return a * b


if __name__ == "__main__":
    app.run()  # starts the worker

On the client side simply call the registered tasks.

# main.py

from tasks import multiply

result = await multiply(2, 3)  # enqueues the tasks and waits for the response