from kombu import Exchange
from kombu import Queue

from app import config


CELERY_DEFAULT_QUEUE = config.broker_queue_name
CELERY_QUEUES = (Queue(
    config.broker_queue_name,
    Exchange(config.broker_queue_name)),)

CELERY_RESULT_BACKEND = config.celery_results_db
CELERY_RESULT_DB_TABLENAMES = {
    'task': 'ows-xlsx_taskmeta',
    'group': 'ows-xlsx_groupmeta',
}

BROKER_TRANSPORT_OPTIONS = {
    'queue_name_prefix': config.queue_prefix
}