(ph>$SSKrSSKJrJr SSKJrJr SSKJr SSKrSSK r SSK J r SSK J r SSKJr SSKJr SS KJr SS KJrJr SS KJr SS KJr SS KJr SSKJr SSKJ r SSK!J"r"J#r# SSK!J$r% SSK&J'r' SSK(J)r)J*r* SSK+J,r,J-r- SSK.J/r/ \R`S:aSSK1Jr2 OSSK3J2r2 \ RlS\4Sj5r7\ RlS.Sj5r8\*RrS\*Rt3/r;S\RxR{\'S5S.S\RxR{\'S5S.S.r>\)RrS\)Rt3/r?S\RxR{\'S5S.S\RxR{\'S5S.S .r@\ RRS!5rC\ RRS"5rD\ RRS#5rE\"\;\>S$9\ RRS%\4S&j55rF\"\?\@S$9\ RRS%\4S'j55rG\ RRS(5rH\ RRS)5rIS*rJ\"S+S,9S-5rKg!\4a SSK5J2r2 GNf=f)/N)datetime timedelta)EventValue)mock)ValidationError)IntegrityError)override_settings)timezone)is_naive)Broker get_broker)Conf)monitor)pusher)Queue) scheduler)Schedulefetch)schedule)BASE_DIR)!TestingMultipleAppsDatabaseRouterTestingReplicaDatabaseRouter) add_months localtime)worker)r)ZoneInforeturncDUR[SS5 [5$)zd Patches the Conf object setting the DJANGO_REDIS attribute allowing a default redis configuration. DJANGO_REDISdefault)setattrrr monkeypatchs P/var/www/html/venv/lib/python3.13/site-packages/django_q/tests/test_scheduler.pybrokerr'(s ni8 <c2UR[SS5 g)zNPatches the Conf object setting the ORM attribute to a database named default.ORMr"N)r#rr$s r& orm_brokerr+2seY/r(.zdjango.db.backends.sqlite3z db.sqlite3)ENGINENAME)writablereplica)r"adminc $UR[SS5 [S5nSUl[ SSSSSS5n[ S SS S [ RUS 9n[US 9 UR5 URn[U5S:XdeURU5n[U5S:Xde[US 9 UR5 URn[U5S:XdeURU5n[U5S:Xde[US 9 UR5 URn[U5S:XdeURU5n[U5S:Xde[ SSSSSS5n[ SSS[ RUS 9n[US 9 UR5 URn[U5S:XdeURU5n[U5S:Xde[US 9 UR5 URn[U5S:XdeURU5n[U5S:Xde[US 9 UR5 URn[U5S:XdeURU5n[U5S:Xdeg)N TIME_ZONEzEurope/Amsterdamscheduler_test:qir math.copysign test math)name schedule_typenext_runr'z2021-03-28 00:00:00+00:00z2021-03-28 01:00:00+01:00z2021-03-28 23:00:00+00:00z2021-03-29 01:00:00+02:00z2021-03-29 23:00:00+00:00z2021-03-30 01:00:00+02:00 "django_q.tests.tasks.word_multiplymultiplyz2021-10-29 23:00:00+00:00z2021-10-30 01:00:00+02:00z2021-10-30 23:00:00+00:00z2021-10-31 01:00:00+02:00z2021-11-01 00:00:00+00:00z2021-11-01 01:00:00+01:00) r#rrlist_keyrcreate_schedulerDAILYrrefresh_from_dbr=str astimezone)r'r%tz start_daterr=s r&)test_scheduler_daylight_saving_time_dailyrLUs k+=> $ %B(FO$2q!Q/J  nn HV   H x=7 77 7""2&H x=7 77 7V   H x=7 77 7""2&H x=7 77 7V   H x=7 77 7""2&H x=7 77 7$B1a0J, nn HV   H x=7 77 7""2&H x=7 77 7V   H x=7 77 7""2&H x=7 77 7V   H x=7 77 7""2&H x=7 77 7r(c  SUlUR5 [SSSSS[RSS9nUR 5be[ R"[5 [SSSSS[RSS9nSSS5 [US9 [5n[5nUR5 [X4US9 UR5S:XdeUR5S :XdeUR!S 5 [5n[#X5[%S S55 UR5S:XdeUR!S 5 ['U5 UR5S :Xde[R(R+UR,S 9nUR.S :XdeUR 5ceUR15S LdeUR2[4R6"5[9SS9-:de[;UR<5nUceUR0S LdeUR>S :de[SSS[R@SSS9n[CUS5S Lde[SSS[RDSSS9n[CUS5S Lde[SSS[RFSS9n [CU S5S Lde[SSS[RHSS9n [CU S5S LdeU RK5beU RM5S:Xde[ R"[N5 [SSS[RHSS9 SSS5 [RPHNn U S [RH:XaM[SSSU S SSS9nUceUR 5be[US9 MP [R(RSSSS[RDS9 [US9 [R(RUUR,S 9RW5SLdeURY[ZSS 5 [4R6"5n [SSS[R[4R6"5[9SS9- SS 9n[US9 [R(R+UR,S 9nUR2U :deURY[ZSS5 [US9 [R(R+UR,S 9nUR2U :deUR5 [SSS[R\S!9n[US9 [R(R+UR,S 9nUR2R_5[a[4R6"5S5R_5:Xde[SSS[RbS!9n[US9 [R(R+UR,S 9nUR2R_5[4R6"5[9SS"9-R_5:XdeUR5 URY[ZS#S$5 [SSSS%S[RS&SS'9n[US9 [5n[5nUR5 [X4US9 UR5S :XdeURY[ZS#S(5 [SSSS)S[RS(SS'9n[US9 [5n[5nUR5 [X4US9 UR5S:Xdeg!,(df  GN=f!,(df  GNC=f)*Nr4r8r7r9r:django_q.tests.tasks.result)r;hookr<repeatsr>rSTOPb)pkThoursrArBdjango)wordr<rPrOrSr?)rWr<minutesz 0 22 * * 1-5)rWr<cronz 0 22 * * 1-122z word="django")funcargskwargsr<FCATCH_UPcatch_up )rWr<r=rP)rWr<)weeks CLUSTER_NAMEsome_cluster_namez"test schedule on a another clustersome_other_cluster_name)r;rOr<clusterrPr"ztest schedule with no cluster)2rD delete_queuerErHOURLYlast_runpytestraisesr rrrsetrqsize queue_sizeputrrrobjectsgetrSrPsuccessr=r nowrrtaskresultONCEhasattrrFMINUTESCRON full_clean__str__rTYPEcreatefilterexistsr#r BIMONTHLYdaterBIWEEKLY) r'r%r task_queue stop_event result_queuers once_schedulealways_scheduleminute_schedule cron_scheduletrrs r&test_schedulerrs(FO    *ooH     && & ~ &"  ."//  'VJJNN :&1     "" "    ! ## #NN67L :U3^4    1 $$ $V L    1 $$ $##x{{#3H   q      ** *     %% %   x||~ 0BB BB B  D    <<4   ;;??#, mm * M =$ '4 // /%, nn * O ?D )T 11 1%, && O ?D )T 11 1#, mm  M =$ '4 // /  # # % -- -  "&J JJ J  ' 0 "--   (]] Q48== " 0 A$.  ###  "***   1 nn V    " "m&6&6 " 7 > > @E II Ij$/ ,,.C, oo)""55 HV##x{{#3H   s "" "j%0 V##x{{#3H   s "" " , (( H V##x{{#3H    ! ! #z(,,.!'D'I'I'K KK K, '' H V##x{{#3H    ! ! # 9K(K'Q'Q'S SS S n.AB  1 *oo) HVJJNN :&1     "" "ni8  , *oo HVJJNN :&1     "" "W ' &\ ( 's"],&]>, ];> ^ c SUlUR5 [R"5[ SS9- n[ SSSSS[ RSUSS 9 nUR5beURS:Xde[US 9 [5n[5nUR5 [XEUS 9 UR5S:XdeUR!5nSUS ;deUS SUR#5:Xdeg) Nr4r7rTr8r9r:rN intended_date)r;rOr<rPr=intended_date_kwargr>r])rDrfr rrrrErrgrhrrrrrkrrlrp isoformat)r'r%run_daterrrrss r&test_intended_schedule_kwargrs(FO ||~  22H   *oo+ H     && &  ' '? :: : VJJNN :&1     "" " >> D d8n ,, , >/ *h.@.@.B BB Br()DATABASE_ROUTERS DATABASESr+c[SS9n[R"S5n[US9 URR SS9 SSS5 g!,(df  g=f)z GIVEN a environment with a read/write configured replica database WHEN the scheduler is called THEN the transaction must be called with the write database. r4rDdjango_q.cluster.db.transactionr>r/usingNrrpatchratomicassert_called_withr+r' mocked_dbs r&/test_scheduler_atomic_must_specify_the_write_dbrsI!3 4F 5 6) ++*+= 7 6 6 #A  Ac[SS9n[R"S5n[US9 URR SS9 SSS5 g!,(df  g=f)z GIVEN a environment without a read replica database WHEN the scheduler is called THEN the transaction atomic must be called using the default connection. r4rrr>r"rNrrs r&Ktest_scheduler_atomic_must_specify_the_database_based_on_router_redirectionrsI!3 4F 5 6) ++)+< 7 6 6rcSn[S[RUS9nURceURbeURnUR 5 URU:deg)zBEnsure Schedule.save() sets next_run correctly for CRON schedules. 0 12 * * * math.sqrtr[r<rYN)rrxr=rSsave)cron_expressionrinitial_next_runs r&)test_schedule_save_sets_next_run_for_cronrsp#O mm H    (( ( ;;  (( MMO   / // /r(c Sn[RRS[RUS9nURceUR[ R "5:de[U5 UR5S:Xdeg)zNEnsure Schedule.save() updates next_run correctly when created directly in DB.rrrNr) rror|rxr=r rrrrm)r'rrs r&test_schedule_save_direct_dbrs#O&& mm 'H    (( (   x||~ -- - f    ! ## #r(c8[[55(aegNr rr(r&test_localtimers $$$ $$r(F)USE_TZc8[[55(degrrrr(r&test_naive_localtimer s IK  r()rN)LosrrmultiprocessingrrunittestrrVridjango.core.exceptionsr django.dbr django.testr django.utilsr django.utils.timezoner django_q.brokersr r django_q.confrdjango_q.monitorrdjango_q.pusherrdjango_q.queuesrdjango_q.schedulerrdjango_q.tasksrrrrEdjango_q.tests.settingsr:django_q.tests.testing_utilities.multiple_database_routersrrdjango_q.utilsrrdjango_q.workerrVERSIONpytzrzoneinfo ImportErrorbackports.zoneinfofixturer'r+ __module____name__REPLICA_DATABASE_ROUTERSpathjoinREPLICA_DATABASESMULTIPLE_APPS_DATABASE_ROUTERSMULTIPLE_APPS_DATABASESmark django_dbrLrrrrrrrrrr(r&rs (( 2$)!*/$"!(*6,1" >>F)0% 600 $../q1M1V1V0WX / X|4 / X|4 )334A6W6`6`5ab" / X|4 / X|4 b8b8JY#Y#xCC>-9J > > >3?V = = =00&$$(%% !!!M 0//0s)I?? JJ