huey_redis_task_queue_quickstart_with_async_enqueue.py

1from huey import RedisHuey
2
3# 1. Create a Huey instance (requires Redis to be running)
4huey = RedisHuey('my-app')
5
6# 2. Decorate a function to make it a task
7@huey.task()
8def add(a, b):
9    return a + b
10
11# 3. To run the task, call it like a normal function
12# but use the .enqueue() or just call the function normally
13# to put it in the queue for the consumer to process.
14if __name__ == '__main__':
15    # This schedules the task to be run by the consumer
16    result = add(1, 2)
17    print(f"Task 'add' has been enqueued. Result object: {result}")
18    
19    # To get the result (blocks until task is finished)
20    # Note: Requires the consumer to be running in a separate process:
21    # $ huey_consumer.py main.huey
22    print(f"Result value: {result.get(blocking=True)}")