
    j9                        d dl mZ d dlmZmZmZ d dlmZ d dlm	Z	 d dl
mZ  eded          Ze                    d	          d
             ZdS )    )annotations)	Blueprintjsonifyrequest)logger)get_health_report)get_task_queue_snapshotdiagnosticsz/diagnostics)
url_prefixz/task-queuec                    t           j                            d          pd                                pd } t           j                            d          pd                                pd }t           j                            d          }	 t	          | ||          }t                      }n@# t          $ r3}t          j        d|           t          ddd	          d
fcY d }~S d }~ww xY wt          |                    d                    |                    d          pi                     d          pi d|d<   t          ddi|          S )N	task_type statuslimit)r   r   r   z)failed to load task queue diagnostics: %sFz%failed to load task queue diagnostics)okerrori  r   checks
task_queue)r   r   healthT)r   argsgetstripr	   r   	Exceptionr   	exceptionr   bool)r   r   r   snapshotr   excs         </home/longshao/multi-rider-rag/modules/diagnostics/routes.pytask_queue_diagnosticsr      sc   !!+..4";;==EIlx((.B5577?4FLW%%E]*YvUZ[[["$$ ] ] ]DcJJJe.UVVWWY\\\\\\\\]
 6::d##$$zz(++1r66|DDJ HX D$+(+,,,s    B, ,
C)6(C$C)$C)N)
__future__r   flaskr   r   r   shared.config.configr   shared.healthr   shared.task_queue_diagnosticsr	   __name__diagnostics_bpr   r        r   <module>r)      s    " " " " " " - - - - - - - - - - ' ' ' ' ' ' + + + + + + A A A A A A =(~NNN M""- - #"- - -r(   