pi_portal.modules.tasks.workers.cron_jobs.queue_metrics.CronJob

class pi_portal.modules.tasks.workers.cron_jobs.queue_metrics.CronJob(*args: Any, **kwargs: Dict[str, Any])

Bases: MetricsLoggerMixin, CronJobBase[Args]

Periodically log metrics for the task queue.

Rather than send a job to queue, this simple job runs directly.

Return type:

MetaPostInitCaller

__init__(log: Logger, registry: TaskRegistry) → None

schedule(scheduler: TaskScheduler) → None

Schedule a task execution.

Parameters:

scheduler (TaskScheduler) – A task scheduler instance.

tick() → None

Advance the cron timer.