queue_job()

Complexity

Conditions

2

Size

Total Lines

15

Duplication

Lines	0
Ratio	0 %

Importance

Changes	1
Bugs	0	Features	1

# -*- coding: utf-8 -*-
def queue_job(redis_connection, queue_name, delegate, *args):
    """

    :param redis_connection: redis connection instance
    :param queue_name: name of the queue to place the job on
    :param delegate: function to be executed by the queue -> 'package.module.function'
    :param args: arguments list used by called function
    :return: id of the job
    """
    logging.info("scheduling job {}".format(delegate))

    with Connection(redis_connection):
        q = Queue(queue_name)
        job = q.enqueue(delegate, *args)
        return job.id