Source code for flask_unchained.bundles.celery.config

import os

from flask_unchained import BundleConfig

from .tasks import _send_mail_async


class Config(BundleConfig):
    """
    Default configuration options for the Celery Bundle.
    """

    CELERY_BROKER_URL = 'redis://{host}:{port}/0'.format(
        host=os.getenv('FLASK_REDIS_HOST', '127.0.0.1'),
        port=int(os.getenv('FLASK_REDIS_PORT', "6379")),
    )
    """
    The broker URL to connect to.
    """

    CELERY_RESULT_BACKEND = CELERY_BROKER_URL
    """
    The result backend URL to connect to.
    """

    CELERY_ACCEPT_CONTENT = ('json', 'pickle', 'dill')
    """
    Tuple of supported serialization strategies.
    """

    MAIL_SEND_FN = _send_mail_async
    """
    If the celery bundle is listed *after* the mail bundle in
    ``unchained_config.BUNDLES``, then this configures the mail bundle to
    send emails asynchronously.
    """