def queued_task(task):
    @functools.wraps(task)
    def wrapped(*args, **kwargs):
        signature = task.si(*args, **kwargs)
        enqueue_task(signature)
    return wrapped
Decorator that adds the wrapped task to the queue on ``g`` if Celery is
dataset/ETHPy150Open CenterForOpenScience/osf.io/framework/celery_tasks/handlers.py/queued_task