Background jobs for Python

from bullmq import Queue

queue = Queue("Paint")
await queue.add("cars", {
    "color": "blue",
    "delay": 30000
})

from bullmq import Worker

async def process(job, token):
    if job.name == "cars":
        await paint_car(job.data["color"])

worker = Worker("Paint", process, {
    "concurrency": 100
})

from bullmq import QueueEvents

queue_events = QueueEvents("Paint")

async def on_completed(job, result):
    print(f"Job {job['jobId']} completed")

async def on_failed(job, err):
    print(f"Job {job['jobId']} failed")

queue_events.on("completed", on_completed)
queue_events.on("failed", on_failed)

from bullmq import Queue

queue = Queue("Paint")

# Repeat job once every day at 3:15 (am)
await queue.add(
    "submarine",
    {"color": "yellow"},
    {
        "repeat": {
            "pattern": "* 15 3 * * *"
        }
    }
)

from bullmq import Worker

async def process(job, token):
    await paint_car(job)

worker = Worker("Paint", process, {
    "limiter": {
        "max": 10,
        "duration": 1000
    }
})

from bullmq import Queue

queue = Queue("Paint")

await queue.add(
    "car",
    {"color": "pink"},
    {
        "attempts": 3,
        "backoff": {
            "type": "exponential",
            "delay": 1000
        }
    }
)

from bullmq import FlowProducer

flow = FlowProducer()

await flow.add({
    "name": "Renovate",
    "queueName": "cars",
    "children": [
        {"name": "paint", "queueName": "steps"},
        {"name": "engine", "queueName": "steps"},
        {"name": "wheels", "queueName": "steps"},
    ]
})