def queued_task(task):
    @functools.wraps(task)
    def wrapped(*args, **kwargs):
        signature = task.si(*args, **kwargs)
        enqueue_task(signature)
    return wrapped
Number of items allowed in the queue.
dataset/ETHPy150Open CenterForOpenScience/osf.io/framework/celery_tasks/handlers.py/queued_task--crossover with--dataset/ETHPy150Open tornadoweb/tornado/tornado/queues.py/Queue.maxsize