SyncTimer

Sync timer for scheduling tasks.

SyncTimer

Bases: BaseTimer

Таймер, работающий через apscheduler, запускающий задачи.

Пример

from qtasks import QueueTasks
from qtasks.timers import SyncTimer

app = QueueTasks()
timer = SyncTimer(app=app)

trigger = CronTrigger(second="*/10") # Запуск каждые 10 секунд
timer.add_task("test", trigger=trigger, args=(2,))

timer.run_forever()

__init__(app, log=None, config=None)

Инициализация таймера.

Parameters:

Name	Type	Description	Default
app	QueueTasks	Приложение.	required
log	Logger	Логгер. По умолчанию: qtasks.logs.Logger.	None
config	QueueConfig	Конфиг. По умолчанию: qtasks.configs.config.QueueConfig.	None

add_task(task_name, trigger, priority=0, args=None, kwargs=None)

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

Parameters:

Name	Type	Description	Default
task_name	str	Имя задачи.	required
priority	int	Приоритет задачи. По умолчанию 0.	0
args	tuple	args задачи. По умолчанию ().	None
kwargs	dict	kwags задачи. По умолчанию {}.	None

Returns:

Type	Description
Job	Any|None: Задача.

run_forever()

Запуск Таймера.