Function
_state_of_task
(request,
is_active=worker_state.active_requests.__contains__,
is_reserved=worker_state.reserved_requests.__contains__)
Source from the content-addressed store, hash-verified
| 122 | |
| 123 | |
| 124 | def _state_of_task(request, |
| 125 | is_active=worker_state.active_requests.__contains__, |
| 126 | is_reserved=worker_state.reserved_requests.__contains__): |
| 127 | if is_active(request): |
| 128 | return 'active' |
| 129 | elif is_reserved(request): |
| 130 | return 'reserved' |
| 131 | return 'ready' |
| 132 | |
| 133 | |
| 134 | @control_command( |
Tested by
no test coverage detected