Function process_queue

salt/runners/queue.py:189–224

Pop items off a queue and create an event on the Salt event bus to be processed by a Reactor. CLI Example: .. code-block:: bash salt-run queue.process_queue myqueue salt-run queue.process_queue myqueue 6 salt-run queue.process_queue myqueue all backend=sql

(queue, quantity=1, backend="sqlite", is_runner=False)

def process_queue(queue, quantity=1, backend="sqlite", is_runner=False):
    """
    Pop items off a queue and create an event on the Salt event bus to be
    processed by a Reactor.

    CLI Example:

    .. code-block:: bash

        salt-run queue.process_queue myqueue
        salt-run queue.process_queue myqueue 6
        salt-run queue.process_queue myqueue all backend=sqlite
    """
    # get ready to send an event
    with get_event(
        "master",
        __opts__["sock_dir"],
        opts=__opts__,
        listen=False,
    ) as event_bus:
        try:
            items = pop(
                queue=queue, quantity=quantity, backend=backend, is_runner=is_runner
            )
        except SaltInvocationError as exc:
            error_txt = f"{exc}"
            __jid_event__.fire_event({"errors": error_txt}, "progress")
            return False

        data = {
            "items": items,
            "backend": backend,
            "queue": queue,
        }
        event_bus.fire_event(data, tagify([queue, "process"], prefix="queue"))
    return data


def __get_queue_opts(queue=None, backend=None):