Source code for hedwig.commands

from hedwig.backends.utils import get_consumer_backend



[docs]def requeue_dead_letter(num_messages: int = 10, visibility_timeout: int = None) -> None:
    """
    Re-queues everything in the Hedwig DLQ back into the Hedwig queue.

    :param num_messages: Maximum number of messages to fetch in one call. Defaults to 10.
    :param visibility_timeout: The number of seconds the message should remain invisible to other queue readers.
        Defaults to None, which is queue default
    """
    consumer_backend = get_consumer_backend(dlq=True)
    consumer_backend.requeue_dead_letter(num_messages, visibility_timeout)