Pop one or more or all items from a queue CLI Example: .. code-block:: bash salt-run queue.pop myqueue salt-run queue.pop myqueue 6 salt-run queue.pop myqueue all salt-run queue.pop myqueue 6 backend=sqlite salt-run queue.pop myqueue all backen
(queue, quantity=1, backend="sqlite", is_runner=False)
| 165 | |
| 166 | |
| 167 | def pop(queue, quantity=1, backend="sqlite", is_runner=False): |
| 168 | """ |
| 169 | Pop one or more or all items from a queue |
| 170 | |
| 171 | CLI Example: |
| 172 | |
| 173 | .. code-block:: bash |
| 174 | |
| 175 | salt-run queue.pop myqueue |
| 176 | salt-run queue.pop myqueue 6 |
| 177 | salt-run queue.pop myqueue all |
| 178 | salt-run queue.pop myqueue 6 backend=sqlite |
| 179 | salt-run queue.pop myqueue all backend=sqlite |
| 180 | """ |
| 181 | queue_funcs = salt.loader.queues(__opts__) |
| 182 | cmd = f"{backend}.pop" |
| 183 | if cmd not in queue_funcs: |
| 184 | raise SaltInvocationError(f'Function "{cmd}" is not available') |
| 185 | ret = queue_funcs[cmd](quantity=quantity, queue=queue, is_runner=is_runner) |
| 186 | return ret |
| 187 | |
| 188 | |
| 189 | def process_queue(queue, quantity=1, backend="sqlite", is_runner=False): |
no test coverage detected