Function jail

t/unit/worker/test_request.py:92–99

(app, task_id, name, request_opts, args, kwargs)

def jail(app, task_id, name, request_opts, args, kwargs):
    request = {'id': task_id}
    request.update(request_opts)
    task = app.tasks[name]
    task.__trace__ = None  # rebuild
    return trace_task(
        task, task_id, args, kwargs, request=request, eager=False, app=app,
    ).retval


class test_Retry: