hash

celeryqueue.mustache

"{{name}}": {
    "exchange": "{{exchange}}",
    "binding_key": "{{binding_key}}"
},

config.mustache

CELERYD_LOG_LEVEL = 'INFO'

CELERY_IMPORTS = (
    'ns_esb.components.event_consumer',
    {{#gearbox.loaded_data_bags.ingestion_deploy}}
    "{{celery_imports}}",
    {{/gearbox.loaded_data_bags.ingestion_deploy}}
)

CELERY_QUEUES = {
    "celery": {
        "exchange": "default",
        "binding_key": "celery"
    },
    {{#gearbox.loaded_data_bags.ingestion_deploy.celery_queues}}
    {{> celeryqueue}}
    {{/gearbox.loaded_data_bags.ingestion_deploy.celery_queues}}
}

data.json

{
  "celery_queues": [
    {
      "exchange": "default",
      "binding_key": "Events.CitiOpenCalaisSubscriber",
      "name": "Events.CitiOpenCalaisSubscriber"
    },
    {
      "exchange": "default",
      "binding_key": "Events.CitiGoogleNewsSubscriber",
      "name": "Events.CitiGoogleNewsSubscriber"
    },
    {
      "exchange": "default",
      "binding_key": "GoogleNews.consume",
      "name": "GoogleNews.consume"
    }
  ],
  "celery_imports": [
    "ns_ingestion.pipelines.tasks"
  ],
  "id": "ingestion_deploy"
}

output.py

CELERYD_LOG_LEVEL = 'INFO'

CELERY_IMPORTS = (
    'ns_esb.components.event_consumer',
    "ns_ingestion.pipelines.tasks",
)

CELERY_QUEUES = {
    "celery": {
        "exchange": "default",
        "binding_key": "celery"
    },
}