Celery Heartbeats Example

celery_heartbeats_example.py

"""
In this example, we're configuring Celery to use heartbeats. 
We've set the worker_heartbeat option to 120 seconds, which means 
that each worker will send a heartbeat message to the broker every 2 minutes. 
This can help to ensure that tasks are not lost if a worker goes offline or crashes.
"""
from celery import Celery

app = Celery('tasks', broker='pyamqp://guest@localhost//')

# Configure Celery to use heartbeats
app.conf.update(
    worker_heartbeat=120,  # Send a heartbeat every 120 seconds
)

@app.task
def add(x, y):
    return x + y