
    s,g                     T    d dl Z d dlmZ ddlmZ ddlmZ erddlmZ ddd	ed
dfdZ	y)    N)TYPE_CHECKING   )IntermediateQueue)Queue)
BaseWorkerworkerr   queuereturnc                     t        j                  dt               t        |j                  |j
                        }|j                  | |       y)a  
    Check whether there are any jobs stuck in the intermediate queue.

    A job may be stuck in the intermediate queue if a worker has successfully dequeued a job
    but was not able to push it to the StartedJobRegistry. This may happen in rare cases
    of hardware or network failure.

    We consider a job to be stuck in the intermediate queue if it doesn't exist in the StartedJobRegistry.
    zNclean_intermediate_queue is deprecated. Use IntermediateQueue.cleanup instead.)
connectionN)warningswarnDeprecationWarningr   keyr   cleanup)r   r	   intermediate_queues      h/var/www/trellinator.diamondhoofcare.com/public_html/venv/lib/python3.12/site-packages/rq/maintenance.pyclean_intermediate_queuer      s?     MMX +599AQAQRvu-    )
r   typingr   r   r   r	   r   r   r   r    r   r   <module>r      s1       1 ".\ .% .D .r   