Function queue_task

aleph/queues.py:25–40

(collection, stage, job_id=None, context=None, **payload)

def queue_task(collection, stage, job_id=None, context=None, **payload):
    taskqueue.queue_task(
        rabbitmq_channel,
        kv,
        collection.id if collection else 0,
        stage,
        job_id=job_id,
        context=context,
        **payload
    )
    if SETTINGS.TESTING and lock.acquire(False):
        from aleph.worker import get_worker

        worker = get_worker()
        worker.process(blocking=False)
        lock.release()


def get_status(collection):