jobs.py

import logging
from time import sleep

from scheduler.helpers.queues import get_queue

_counter = 0


def arg_callable():
    global _counter
    _counter += 1
    return _counter


def test_args_kwargs(*args, **kwargs):
    func = "test_args_kwargs({})"
    args_list = [repr(arg) for arg in args]
    kwargs_list = [f"{k}={v}" for (k, v) in kwargs.items()]
    return func.format(", ".join(args_list + kwargs_list))


def two_seconds_job():
    sleep(2)
    logging.info(f"Job {_counter}")


def long_job():
    sleep(1000)
    logging.info(f"Job {_counter}")


test_non_callable = "I am a teapot"


def failing_job():
    raise ValueError


def test_job():
    return 1 + 1


def enqueue_jobs():
    queue = get_queue()
    for i in range(20):
        queue.create_and_enqueue_job(test_job, name=f"job_{i:03}", args=())