
    (ph8"                        S SK r S SKJr  S SKrS SKJrJr  S SKJr  S SK	J
r
  S SKJrJr  S rS rS	 r\R"                  R%                  \ R&                  " S
5      (       + SS9S 5       r\R"                  R%                  \ R&                  " S5      (       + SS9S 5       r\R"                  R,                  S 5       r\R"                  R,                  S 5       rg)    N)sleep)Broker
get_broker)Conf)uuid)
MONGO_HOST
REDIS_HOSTc                    [        5       nUR                  S5        UR                  5         UR                  5         UR	                  5         UR                  5         UR                  S5        UR                  5         UR                  S5        UR                  5         UR                  5         UR                  S5      b   eUR                  SSS5        UR                  S5      S:X  d   eUR                  S5      S   S:X  d   eU R                  [        SS5        UR!                  5       Ul        UR                  S5      b   eUR                  SSS5        UR                  S5      b   eUR                  S5      b   eg )	Ntestidtest_1   ztest:*r   CACHEnot_configured)r   enqueuedequeue
queue_size	lock_sizepurge_queuedeletedelete_queueacknowledgepinginfoget_statset_stat	get_statssetattrr   	get_cachecachemonkeypatchbrokers     N/var/www/html/venv/lib/python3.13/site-packages/django_q/tests/test_brokers.pytest_brokerr%      sI   XF
NN6
NN



MM$

v
KKM
KKM??8$,,,
OOHfa(??8$...H%a(F222g'78##%FL??8$,,,
OOHfa(??8$,,,H%---    c                 H   U R                  [        SS 5        [        5       nUR                  5       SL d   eUR	                  5       c   eU R                  [        S[
        SS.5        [        5       n[        R                  " [        5         UR                  5         S S S 5        U R                  [        SS[
         S35        [        5       n[        R                  " [        5         UR                  5         S S S 5        g ! , (       d  f       Nk= f! , (       d  f       g = f)NDJANGO_REDISTREDISiw  hostportzredis://z:7799)	r   r   r   r   r   r	   pytestraises	Exceptionr!   s     r$   
test_redisr0   &   s    nd3\F;;=D   ;;=$$$g
D'IJ\F	y	! 
"g*U'CD\F	y	! 
"	!	 
"	! 
"	!s   D(D
D
D!c                     U R                  [        SS5        [        5       nUR                  5       SL d   eUR	                  5       c   eUR
                  R                  S:X  d   eg )NBROKER_CLASSz#django_q.brokers.redis_broker.RedisTRedis)r   r   r   r   r   	__class____name__r!   s     r$   test_customr6   5   s\    n.ST\F;;=D   ;;=$$$$$///r&   IRON_MQ_TOKENzrequires IronMQ credentials)reasonc                 r   U R                  [        S[        R                  " S5      [        R                  " S5      S.5        [	        [        5       S   S9nUR                  5       SL d   eUR                  5       c   eUR                  S5        UR                  5         UR                  5       S:X  d   eUR                  S5        UR                  5       S   nUS	   S:X  d   eUR                  US   5        UR                  5       b   eUR                  S5      nUR                  U5        UR                  5       b   eUR                  S5      nUR                  U5        [        S
5       H  nUR                  S5        M     U R                  [        SS
5        UR                  5       nU H  nUc   eUR                  US   5        M     UR                  US   5        UR                  S5        UR                  S5        UR                  5         UR                  5       b   eUR!                  5         g )NIRON_MQr7   IRON_MQ_PROJECT_ID)token
project_idr   list_keyTr         BULK)r   r   osgetenvr   r   r   r   r   r   r   r   r   r   failranger   r"   r#   tasktask_id_taskss         r$   test_ironmqrL   =   s    YY/))$89	
 +F;;=D   ;;=$$$
NN6
!###
NN6>>AD7f
tAw>>### nnV$G
MM'>>###nnV$G
KK1Xv fa(NNE47#  tAw
NN6
NN6
>>###
r&   AWS_ACCESS_KEY_IDzrequires AWS credentialsc           	         U R                  [        S[        R                  " S5      [        R                  " S5      [        R                  " S5      SS.5        [	        SS9nS	[        R
                  ;   d   eS
[        R
                  ;   d   eUR                  5       SL d   eUR                  5       c   eUR                  5       S:X  d   eUR                  S5        UR                  5       S   nUS   S:X  d   eUR                  US   5        UR                  5       b   eU R                  [        SS5        UR                  S5        [        S5        UR                  5       nU(       d  [        R                  " S5        US   n[        U5      S:  d   eUR                  US   5        [        S5        U R                  [        SS5        UR                  S5        [        S5        UR                  5       nU(       d  [        R                  " S5        US   S   nUR!                  U5        UR                  5       b   eUR                  S5        Uc  UR                  5       S   nUc  M  UR#                  US   S   5        [%        S5       H  nUR                  S5        M     U R                  [        SS5        UR                  5       nU H  nUc   eUR                  US   5        M     UR                  US   5        UR'                  5       S:X  d   eUR                  S5        UR)                  5         UR+                  5         g )NSQS
AWS_REGIONrM   AWS_SECRET_ACCESS_KEYrA   )
aws_regionaws_access_key_idaws_secret_access_key!receive_message_wait_time_secondstestingr>   rU   rR   Tr   r   r@   RETRY   zSQS being weird<   
   rB      )r   r   rC   rD   r   rO   r   r   r   r   r   r   r   r-   skiplenr   rE   rF   r   r   r   rG   s         r$   test_sqsr^   |   s    ))L1!#+>!?%'YY/F%G12		
	 +F.$((:::488###;;=D   ;;=$$$!###
NN6>>AD7f
tAw>>###gq)
NN6	!H>>D%&7Dt9q==
tAw	!Hgr*
NN6	!H>>D%&1gajG
MM'>>###
NN6
,~~" ,
KKQ
2Yv fb)NNE47#  tAw"""
NN6

r&   c                 
   U R                  [        SS5        [        SS9nUR                  5       SL d   eUR	                  5       c   eUR                  5         UR                  S5        UR                  5       S:X  d   eUR                  5       S   nUS   S:X  d   eUR                  US   5        UR                  5       S:X  d   eU R                  [        S	S5        UR                  S5        UR                  5       S:X  d   eUR                  5         UR                  5       S:X  d   e[        S
5        UR                  5       S:X  d   eUR                  5       S   nUR                  5       S:X  d   eUR                  US   5        [        S
5        UR                  5       S:X  d   eUR                  S5      nUR                  U5        UR                  5       b   eUR                  S5      nUR                  U5        [        S5       H  nUR                  S5        M     U R                  [        SS5        UR                  5       nUR                  5       [        R                  :X  d   eU H  nUc   eUR                  US   5        M     UR                  5       S:X  d   eUR                  US   5        UR                  S5        UR                  S5        UR                  5         UR                  5       S:X  d   eg )NORMdefaultorm_testr>   Tr   r@   r   rW         ?rA   rB   )r   r   r   r   r   r   r   r   r   r   r   r   rE   rF   r   rB   rG   s         r$   test_ormrd      s   eY/,F;;=D   ;;=$$$

NN6!###>>AD7f
tAw!###gq)
NN6!###
NN!###	#J!###>>AD!###
tAw	#J!###nnV$G
MM'>>###nnV$G
KK1Xv fa(NNE***47#  """
tAw
NN6
NN6
!###r&   c                 .   U R                  [        S[        SS.5        [        SS9nUR	                  5       SL d   eUR                  5       c   eUR                  5         UR                  S5        UR                  5       S:X  d   eUR                  5       S	   nUS   S:X  d   eUR                  US	   5        UR                  5       S	:X  d   eU R                  [        S
S5        UR                  S5        UR                  5       S:X  d   eUR                  5         UR                  5       S	:X  d   e[        S5        UR                  5       S:X  d   eUR                  5       S	   nUR                  5       S	:X  d   eUR                  US	   5        [        S5        UR                  5       S	:X  d   eUR                  S5      nUR                  U5        UR                  5       b   eUR                  S5      nUR                  U5        [        S5       H  nUR                  S5        M     [        S5       Vs/ s H  oAR                  5       S	   PM     nnUR                  5       S:X  d   eU H  nUc   eUR                  US	   5        M     UR                  5       S	:X  d   eUR                  US	   5        UR                  S5        UR                  S5        UR!                  5         UR                  5         UR                  5       S	:X  d   eg s  snf )NMONGOii  r*   
mongo_testr>   Tr   r@   r   rW   rc   rA   )r   r   r   r   r   r   r   r   r   r   r   r   r   rE   rF   r   r   rG   s         r$   
test_mongorh      s   g
E'JK.F;;=D   ;;=$$$

NN6!###>>AD7f
tAw!###gq)
NN6!###
NN!###	#J!###>>AD!###
tAw	#J!###nnV$G
MM'>>###nnV$G
KK1Xv */(3(Q^^a (E3"""47#  """
tAw
NN6
NN6

!### 4s   9L)rC   timer   r-   django_q.brokersr   r   django_q.confr   django_q.humanhashr   django_q.tests.settingsr   r	   r%   r0   r6   markskipifrD   rL   r^   	django_dbrd   rh    r&   r$   <module>rr      s    	   /  # :.40 
		/""+H  99x 
		%&&/I  BBJ 5$ 5$p 5$ 5$r&   