Permalink
Switch branches/tags
Nothing to show
Find file Copy path
Fetching contributors…
Cannot retrieve contributors at this time
20 lines (16 sloc) 463 Bytes
import os
from celery import Celery
CELERY_BROKER_URL = os.environ['CELERY_BROKER_URL']
app = Celery(__name__)
app.conf.update({
'broker_url': os.environ['CELERY_BROKER_URL'],
'imports': (
'tasks',
),
'task_routes': {
'fetch_bitcoin_price_index': {'queue': 'feeds'},
'calculate_moving_average': {'queue': 'filters'}
},
'task_serializer': 'json',
'result_serializer': 'json',
'accept_content': ['json']})