(phSSKJrJr SSKrSSKJr SSKJr SSKJ r SSK J r SSK J r SSKJrJrJrJrJrJrJrJrJrJrJrJrJr SS KJr \R<S 5r\R@RBS 5r"\R@RBS 5r#\R@RBS 5r$\R@RBS5r%g))EventValueN) get_broker)Conf)monitor)pusher)Queue) AsyncTaskChainIter async_chain async_iter async_task count_group delete_cached delete_groupfetch fetch_groupresult result_group)workercDUR[SS5 [5$)N DJANGO_REDISdefault)setattrrr) monkeypatchs M/var/www/html/venv/lib/python3.13/site-packages/django_q/tests/test_cached.pybrokerrsni8 <c `UR5 URR5 Sn[SSSSUS9n[SSSSXS9 [SSSSXS9 [SSSSXS9 [SSSSXS9 [SSSSXS9 [SSSSXS9 [ S [ S 5Vs/sHo3PM snSS 9n[ US SS 9be[US SS 9be[US SS 9be[US S SS9be[US SS 9be[US S SS9beSnUR5U:Xde[5n[5nUR5 [ U5H n[XgUS9 M UR5S:XdeUR5U:XdeUR!S5 [5n[#Xh[%SS55 UR5U:XdeUR!S5 ['U5 UR5S:Xde[ USSS 9S:Xde[USSS 9R S:Xde[U5be[)USS 9S:Xde[)USSS9S:Xde[USS 9/SQ:Xde[+[USSS95S:Xde[+[USS 95S:Xde[+[USSS95S:Xde[-USS 9 [)USS 9be[/U5 [ USS 9be[USS 9be[ U5be[ USS 9ceURR5 gs snf)N cache_test math.copysignT)cachedr)r%rgroupz math.popysign math.floor r%)waitr%)countr*r%)rrSTOPfi)r%failures)r$r$r$r$r$F) purge_queuecacheclearrrrangerrrr queue_sizer rsetrqsizeputrrrrlenrr) rr&task_idiiter_id task_count task_queue stop_event result_queues r test_cachedrC"sx  LL E!RVLG2d6O2d6O2d6O2d6O2d6O2d6O59'=9a9'=dKG '4 0 88 8 r$ / 77 7 Bt 4 << < QR = EE E u2d 3 ;; ; uABt < DD DJ    * ,, ,JJNN : zf5    ! ## #     ++ +NN67L :U3^4    : -- -V L    1 $$ $ 'D 1R 77 7 s4 0 7 72 == = > !! ! uT *a // / uTD 9Q >> > d +/C CC C |E$> ?1 DD D {5. /1 44 4 {5> ?1 DD Dt$ uT * 22 2' '$ ' // /  & .. . '? "" " '$ ' 33 3 LL](>s L+ cUR5 URR5 [S5Vs/sHoPM nn/SQnSn[ SUSS9n[ SUSS9n[ SUSS9n[ SSSS9n[ U5n U ce[ U5n U R U :Xde[ U5ce[ U5ce[ U5S S :Xde[SSSS 9nURS S 5 URS S 5 URSS5 URSS5 URSLdeUR5S:XdeUR5ce[UR 55S:Xde[UR 5R 5S:XdeURS S5 UR 5beUR5 [UR 55S:Xdegs snf)Nr()r#r$)r+r$))r2r0)r#r+rFr2r'Tsyncr")r#rr#rJr%r$r+rFrGr2r0FrHi) r3r4r5r6rrrr appendstartedlengthrunr;) rr=itit2it3tt2t3t4result_ttask_ts r test_iterrY`s  LL2Y Y!YB  -C C<$/A OSt 4B L#D 1B L$T 2BayH    1XF ==H $$ $ ": !! ! ": !! ! ":a=A   _45AHHQOHHQOHHQOHHQN 99   88:?? 557   qxxz?a   qwwy A %% %HHQO 88:  EEG qxxz?a  9 s G>c UR5 URR5 [SS9nUR SS5 UR SSS5 UR SS5 UR 5S:XdeUR 5beUR5 URS S 9nUR 5UR 5:Xde[U5UR 5:XdeUR5n[U5UR 5:XdeSUl UR SS5 UR 5S :XdeUR5 URS S 9nUR 5UR 5:Xde[U5UR 5:XdeUR5n[U5UR 5:Xde[S S /SSS 9n[USS9SS/:Xdeg)NTrIr'r#r"r$r+rFi)r*rHzdjango_q.tests.tasks.hellorKr)hello)r3r4r5r rLrNcurrentrOrr;rr%r r)r task_chainrrSrids r test_chainr`s  LLD!JlA&oq"-lA&    ! ## #     '' 'NNt$A    :#4#4#6 66 6 q6Z&&( (( (A q6Z&&( (( (JlA&    ! ## #NNt$A    :#4#4#6 66 6 q6Z&&( (( (A q6Z&&( (( (  %'CD  C D )gw-? ?? ?rc .UR5 URR5 [S5nURS:XdeSUlUR SLdeSUlUR(deSUlUR(deXl URU:XdeUR5 UR5S:XdeUR5RS:Xde[SSSSSUS9nUR5 UR5S:Xde[SSSSSUS.S9nUR(aeSUlURS S SLdeUR5 UR5S:XdeS UlURS :XdeSUlUR(aeS UlUR S :XdeUR SLdeUR5 UR#5S/:XdeUR%5UR5/:XdeUR'[(S S5 UR'[(SS5 [SS5nUR5 UR5S:Xdeg)Nr"rEFTr$r#)r%rJr) q_optionsrbrJasync_class_testzdjq.tests.tasks.helloSYNCCACHEDr'g?)r3r4r5r funcargsrMr%rJrrOrrkwargsr&savehookrrrr)rras rtest_asynctask_classrlsA  LL/"A 66_ $$ $ AF 99  AH 88O8 AF 66M6H 88v  EEG 88:   779  r !! !/1bDPAEEG 88:    !5FC  A vv: AF 88K  (D 00 0EEG 88:   AG 77( (( ( AFvv: $AF 66, ,, , 99  EEG >> t ## # ==?qwwyk )) )fd+h-,$AEEG 88:??r)&multiprocessingrrpytestdjango_q.brokersr django_q.confrdjango_q.monitorrdjango_q.pusherrdjango_q.queuesr django_q.tasksr r r r rrrrrrrrrdjango_q.workerrfixturermark django_dbrCrYr`rlrrrzs( '$"!# ::z  D@@B//r