BaseStarter - Пишем свой запуск

Base starter.

BaseStarter

Bases: ABC

BaseStarter - Абстрактный класс, который является фундаментом для Стартеров.

Пример

from qtasks import QueueTasks
from qtasks.starters.base import BaseStarter

class MyStarter(BaseStarter):
    def __init__(self, name: str = None, broker = None, worker = None):
        super().__init__(name=name, broker = None, worker = None)
        pass

__init__(name=None, broker=None, worker=None, log=None, config=None)

Инициализация базового стартера.

Parameters:

Name	Type	Description	Default
name	str	Имя проекта. По умолчанию: None.	None
broker	BaseBroker	Брокер. По умолчанию: None.	None
worker	BaseWorker	Воркер. По умолчанию: None.	None
log	Logger	Логгер. По умолчанию: qtasks.logs.Logger.	None
config	QueueConfig	Конфиг. По умолчанию: qtasks.configs.config.QueueConfig.	None

add_plugin(plugin, trigger_names=None)

Добавить плагин в класс.

Parameters:

Name	Type	Description	Default
plugin	BasePlugin	Плагин	required
trigger_names	List[str]	Имя триггеров для плагина. По умолчанию: будет добавлен в Globals.	None

init_plugins()

Инициализация плагинов.

start() abstractmethod

Запуск Стартера. Эта функция задействуется основным экземпляром QueueTasks через run_forever.

stop() abstractmethod

Останавливает Стартер. Эта функция задействуется основным экземпляром QueueTasks после завершения функции run_forever.

update_configs(config)

Обновить конфиги всем компонентам.

Parameters:

Name	Type	Description	Default
config	QueueConfig	Конфиг.	required