o i@sVddlZddlmZddlmZddlmZerddlmZddd ed dfd d Z dS) N) TYPE_CHECKING)IntermediateQueue)Queue) BaseWorkerworkerrqueuereturncCs,tdtt|j|jd}|||dS)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)warningswarnDeprecationWarningrkeyr cleanup)rrintermediate_queuerE/home/app/Keep/.python/lib/python3.10/site-packages/rq/maintenance.pyclean_intermediate_queue s  r) r typingrrrrrrrrrrrrs