
    (ph                         S SK r S SKrS SKJr  S SKJr  S SKJr  S SKJ	r	J
r
Jr  S SKJr  S SKJr  \R                   R"                  S 5       r\R                   R"                  S	 5       rS
 rg)    N)
get_broker)Cluster)Conf)get_idsinfomonitor)Stat
async_taskc                    [         R                  " 5       n[        R                  " SUS9R                  S:X  d   e[        5       nUR                  5         [        SS9n[        5       SL d   eUR                  5         [        U5      S:  d   eSnU HL  nUR                  UR                  :X  d  M  SnUR                  5       S:  d   eUR                  5       SL d   e  O   U(       d   eU R                  [        SS5        [!        S5      nUR#                  S	5        UR%                  5         UR'                  5       S
:X  d   e[        SUS9  UR)                  5         g )Nr   )pid
cluster_idT)run_onceFORMdefaultmonitor_testtest   )r   broker)uuiduuid4r	   getsentinelr   startr   r   stoplenr   uptimeempty_queuessetattrr   r   enqueuedequeue	lock_sizedelete_queue)monkeypatchr   cstatsfound_cstatbs          N/var/www/html/venv/lib/python3.13/site-packages/django_q/tests/test_monitor.pytest_monitorr+      s#   J88j1::a???	AGGIT"E9FFHu:>>G??all*G;;=1$$$$$&$...  N7eY/>"AIIfIIK;;=AT!$NN    c                      [        5         [        5         [        5         [        S5       H  n [        5         M     [        5         g )N   )r   do_syncrange)_s    r*   	test_infor2   )   s)    FIF2Y	 Fr,   c                      [        SSSSS9  g )Nzdjango_q.tests.tasks.countdownr   T)syncsaver
    r,   r*   r/   r/   3   s    /DIr,   )r   pytestdjango_q.brokersr   django_q.clusterr   django_q.confr   django_q.monitor_terminalr   r   r   django_q.statusr	   django_q.tasksr   mark	django_dbr+   r2   r/   r6   r,   r*   <module>r@      sb      ' $  < <   %  6  Jr,   