Add new queue for callbacks

This commit is contained in:
venusbb
2017-12-13 10:57:08 +00:00
parent d18b81093c
commit 11152ab117
2 changed files with 3 additions and 1 deletions

View File

@@ -31,6 +31,7 @@ class QueueNames(object):
NOTIFY = 'notify-internal-tasks' NOTIFY = 'notify-internal-tasks'
PROCESS_FTP = 'process-ftp-tasks' PROCESS_FTP = 'process-ftp-tasks'
CREATE_LETTERS_PDF = 'create-letters-pdf' CREATE_LETTERS_PDF = 'create-letters-pdf'
CALLBACKS = 'service-callbacks'
@staticmethod @staticmethod
def all_queues(): def all_queues():
@@ -46,6 +47,7 @@ class QueueNames(object):
QueueNames.RETRY, QueueNames.RETRY,
QueueNames.NOTIFY, QueueNames.NOTIFY,
QueueNames.CREATE_LETTERS_PDF, QueueNames.CREATE_LETTERS_PDF,
QueueNames.CALLBACKS,
] ]

View File

@@ -56,6 +56,6 @@ applications:
NOTIFY_APP_NAME: delivery-worker NOTIFY_APP_NAME: delivery-worker
- name: notify-delivery-worker-receipts - name: notify-delivery-worker-receipts
command: scripts/run_app_paas.sh celery -A run_celery.notify_celery worker --loglevel=INFO --concurrency=11 -Q ses-callbacks command: scripts/run_app_paas.sh celery -A run_celery.notify_celery worker --loglevel=INFO --concurrency=11 -Q ses-callbacks, service-callbacks
env: env:
NOTIFY_APP_NAME: delivery-worker-receipts NOTIFY_APP_NAME: delivery-worker-receipts