celery.py

from __future__ import absolute_import

from celery import Celery

app = Celery('workers',
             broker='amqp://user:pass@localhost:5000/vhost',
             include=['workers.tasks'])

app.conf.update(
  CELERY_TASK_RESULT_EXPIRES=3600,
)

if __name__ == '__main__':
  app.start()