Process queued runners quantity number of runners to process queue queue to insert the runner reference into backend backend that to use for the queue CLI Example: .. code-block:: bash salt-run queue.process_runner salt-run queue
(quantity=1, queue=None, backend=None)
| 274 | |
| 275 | |
| 276 | def process_runner(quantity=1, queue=None, backend=None): |
| 277 | """ |
| 278 | Process queued runners |
| 279 | |
| 280 | quantity |
| 281 | number of runners to process |
| 282 | |
| 283 | queue |
| 284 | queue to insert the runner reference into |
| 285 | |
| 286 | backend |
| 287 | backend that to use for the queue |
| 288 | |
| 289 | CLI Example: |
| 290 | |
| 291 | .. code-block:: bash |
| 292 | |
| 293 | salt-run queue.process_runner |
| 294 | salt-run queue.process_runner 5 |
| 295 | |
| 296 | """ |
| 297 | queue_kwargs = __get_queue_opts(queue=queue, backend=backend) |
| 298 | data = process_queue(quantity=quantity, is_runner=True, **queue_kwargs) |
| 299 | for job in data["items"]: |
| 300 | __salt__[job["fun"]](*job["args"], **job["kwargs"]) |
nothing calls this directly
no test coverage detected