from celery import Celery
from cesium import _patch_celery

celery_config = {
    'CELERY_ACCEPT_CONTENT': ['pickle'],
    'CELERY_IMPORTS': ['cesium', 'cesium._patch_celery', 'cesium.celery_tasks'],
    'CELERY_RESULT_BACKEND': 'amqp',
    'CELERY_RESULT_SERIALIZER': 'pickle',
    'CELERY_TASK_SERIALIZER': 'pickle',
    'INSTALLED_APPS': ['cesium'],
    'CELERY_BROKER': 'amqp://guest@localhost//'
}
app = Celery('cesium', broker=celery_config['CELERY_BROKER'])
app.config_from_object(celery_config)

@@ -53,16 +53,28 @@
 celery%0A%0A
+import os%0A%0A%0A
 celery_c
@@ -378,16 +378,48 @@
 BROKER':
+ os.environ.get('CELERY_BROKER',
  'amqp:/
@@ -441,11 +441,13 @@
 t//'
+)
 %0A%7D%0A
+%0A
 app 

Allow broker to be overridden