Add an item or items to a queue CLI Example: .. code-block:: bash salt-run queue.insert myqueue myitem salt-run queue.insert myqueue "['item1', 'item2', 'item3']" salt-run queue.insert myqueue myitem backend=sqlite salt-run queue.insert myqueue "['item
(queue, items, backend="sqlite")
| 67 | |
| 68 | |
| 69 | def insert(queue, items, backend="sqlite"): |
| 70 | """ |
| 71 | Add an item or items to a queue |
| 72 | |
| 73 | CLI Example: |
| 74 | |
| 75 | .. code-block:: bash |
| 76 | |
| 77 | salt-run queue.insert myqueue myitem |
| 78 | salt-run queue.insert myqueue "['item1', 'item2', 'item3']" |
| 79 | salt-run queue.insert myqueue myitem backend=sqlite |
| 80 | salt-run queue.insert myqueue "['item1', 'item2', 'item3']" backend=sqlite |
| 81 | """ |
| 82 | queue_funcs = salt.loader.queues(__opts__) |
| 83 | cmd = f"{backend}.insert" |
| 84 | if cmd not in queue_funcs: |
| 85 | raise SaltInvocationError(f'Function "{cmd}" is not available') |
| 86 | ret = queue_funcs[cmd](items=items, queue=queue) |
| 87 | return ret |
| 88 | |
| 89 | |
| 90 | def delete(queue, items, backend="sqlite"): |
no test coverage detected