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)

from celery import Celery
from cesium import _patch_celery

import os


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': os.environ.get('CELERY_BROKER', 'amqp://guest@localhost//')
}

app = Celery('cesium', broker=celery_config['CELERY_BROKER'])
app.config_from_object(celery_config)

Allow broker to be overridden
Allow broker to be overridden

  from celery import Celery
  from cesium import _patch_celery
+ 
+ import os
+ 
  
  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//'
+     'CELERY_BROKER': os.environ.get('CELERY_BROKER', 'amqp://guest@localhost//')
  }
+ 
  app = Celery('cesium', broker=celery_config['CELERY_BROKER'])
  app.config_from_object(celery_config)
  
Allow broker to be overridden
## Code Before:
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)

## Instruction:
Allow broker to be overridden
## Code After:
from celery import Celery
from cesium import _patch_celery

import os


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': os.environ.get('CELERY_BROKER', 'amqp://guest@localhost//')
}

app = Celery('cesium', broker=celery_config['CELERY_BROKER'])
app.config_from_object(celery_config)
