MCPcopy
hub / github.com/celery/celery / task_reserved

Function task_reserved

celery/worker/state.py:96–101  ·  view source on GitHub ↗

Update global state when a task has been reserved.

(request,
                  add_request=requests.__setitem__,
                  add_reserved_request=reserved_requests.add)

Source from the content-addressed store, hash-verified

94
95
96def task_reserved(request,
97 add_request=requests.__setitem__,
98 add_reserved_request=reserved_requests.add):
99 """Update global state when a task has been reserved."""
100 add_request(request.id, request)
101 add_reserved_request(request)
102
103
104def task_accepted(request,

Callers 3

_limit_move_to_poolMethod · 0.90
apply_eta_taskMethod · 0.90
task_message_handlerFunction · 0.85

Calls

no outgoing calls

Tested by

no test coverage detected