bullmq_python_queue_worker_quickstart_example.py

1import asyncio
2from bullmq import Queue, Worker
3
4async def process(job, job_token):
5    print(f"Processing job {job.id} with data {job.data}")
6    # Do some work here
7    await asyncio.sleep(1)
8    return {"status": "completed"}
9
10async def main():
11    # Setup the worker to process jobs from the 'my_queue'
12    worker = Worker("my_queue", process)
13
14    # Setup the queue to add jobs
15    queue = Queue("my_queue")
16
17    # Add a job to the queue
18    job = await queue.add("my_job", {"foo": "bar"})
19    print(f"Added job {job.id}")
20
21    # Keep the script running to allow the worker to process
22    await asyncio.sleep(5)
23    
24    await worker.close()
25    await queue.close()
26
27if __name__ == "__main__":
28    asyncio.run(main())