SyncThreadWorker

Init module for sync worker.

SyncThreadWorker

Bases: BaseWorker, SyncPluginMixin

Воркер, Получающий из Брокера задачи и обрабатывающий их.

Пример

from qtasks import QueueTasks
from qtasks.workers import SyncThreadWorker

worker = SyncThreadWorker()
app = QueueTasks(worker=worker)

__init__(name='QueueTasks', broker=None, log=None, config=None)

Инициализация синхронного воркера.

Parameters:

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

add(name, uuid, priority, created_at, args, kwargs)

Добавление задачи в очередь.

Parameters:

Name	Type	Description	Default
name	str	Имя задачи.	required
uuid	UUID	UUID задачи.	required
priority	int	Приоритет задачи.	required
created_at	float	Создание задачи в формате timestamp.	required
args	tuple	Аргументы задачи типа args.	required
kwargs	dict	Аргументы задачи типа kwargs.	required

init_plugins()

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

remove_finished_task(task_func, task_broker, model)

Обновляет данные хранилища через функцию self.storage.remove_finished_task.

Parameters:

Name	Type	Description	Default
task_func	TaskExecSchema	Схема функции задачи. По умолчанию: None.	required
task_broker	TaskPrioritySchema	Схема приоритетной задачи.	required
model	TaskStatusNewSchema | TaskStatusErrorSchema | TaskStatusCancelSchema	Модель результата задачи.	required

start(num_workers=4)

Запускает несколько обработчиков задач.

Parameters:

Name	Type	Description	Default
num_workers	int	Количество воркеров. По умолчанию: 4.	4

stop()

Останавливает воркеры.

update_config(config)

Обновляет конфиг.

worker(number)

Обработчик задач.

Parameters:

Name	Type	Description	Default
number	int	Номер Воркера.	required