Settings

class arend.settings.ArendSettings(*, beanstalkd: BeanstalkdSettings, backend: Union[MongoSettings, RedisSettings], task_max_retries: int = 3, task_retry_backoff_factor: int = 1, task_priority: int = 1, task_delay: int = 0)

Defines settings for the Arend

Usage:

>>> from arend import arend_task
>>> from arend.backends.mongo import MongoSettings
>>> from arend.brokers import BeanstalkdSettings
>>> from arend.settings import ArendSettings
>>> from arend.worker import consumer
>>>
>>> settings = ArendSettings(
>>>     beanstalkd=BeanstalkdSettings(host="beanstalkd", port=11300),
>>>     backend=MongoSettings(
>>>         mongo_connection="mongodb://user:pass@mongo:27017",
>>>         mongo_db="db",
>>>         mongo_collection="Tasks"
>>>     ),
>>>     task_max_retries = 3
>>>     task_retry_backoff_factor = 1
>>>     task_priority = 0
>>>     task_delay = 1
>>> )

get_backend() → Type[Union[MongoTask, RedisTask]]

Return a Task Backend with configuration already set

class arend.settings.BeanstalkdSettings(*, host: str, port: int)

Defines settings for the Beanstalkd Queue