(phVJSrSSKJr SSKJrJr SSKJr SSKJr SSK J r SSK J r J r SSKJr SS KJrJr SS KJr SS KJr SS KJr S rSrS\ R64SjrS)SjrSSS\ R64SjrS*SjrS\ R64Sjr S)Sjr!SSS\ R64Sjr"S+Sjr#S\ R64Sjr$S,Sjr%S\ R64Sjr&S-Sjr'S-Sjr(S-Sjr)S r*S\ R6\ RVS4S!jr,"S"S#5r-"S$S%5r."S&S'5r/S(r0g).zProvides task functionality.)Value)sleeptime)IntegrityError)timezone) get_broker)Conflogger)uuid)ScheduleTask)Queue) pre_enqueue) SignedPackagec@UR5nSnURS05n[5nUSURSS5=(d URSS5=(d USUUS.nUH1nU(a X;aXXXx'MX;dMURU5Xx'M3 URSS5=(d [UR S 55n S U;a([ R (a[ R US 'S U;a([ R(a[ RUS 'S U;a([ R(a[ RUS 'X7S '[R"5US'[R"SUS9 [R"U5n UR S S5(a [U 5$U R!U 5n ["R$"SU R&SU 35 ["R("SU35 US$)zQueue a task for the cluster.) hookgroupsavesynccached ack_failure iter_count iter_cachedchainbrokerclustertimeout q_options task_nameNr)idnamefuncargsrrrrrkwargsstarteddjango_q)sendertaskFz Enqueued [z] zPushed r!)copypopr rgetr CACHEDSYNC ACK_FAILURESrnowrsendrdumps_syncenqueuer infolist_keydebug) r#r$r%keywordsopt_keysrtagr)keyrpack enqueue_ids A/var/www/html/venv/lib/python3.13/site-packages/django_q/tasks.py async_taskr?s{{}H H ["-I &C!f [$/ ==d + q6  D )!DI _ S)DI  XXh % HDHHY4G)HFt X TdiiyyV D T%6%6"//]NllnDOJT2   t $D xxT{%J KK*V__-R |<= LL73%! :cxURSS5nURSS5nURS[R5nURSS5nURSS5nURS[R"55nURS S5n URS S5n URS S5n U(a;[R R US 9R5(a [S 5e[UUUUUUUUUU U U S9 n U R5 U R5 U $)aQ Create a schedule. :param func: function to schedule. :param args: function arguments. :param name: optional name for the schedule. :param hook: optional result hook function. :type schedule_type: Schedule.TYPE :param repeats: how many times to repeat. 0=never, -1=always. :param next_run: Next scheduled run. :type next_run: datetime.datetime :param cluster: optional cluster name. :param cron: optional cron expression :param intended_date_kwarg: optional identifier to pass intended schedule date. :param kwargs: function keyword arguments. :return: the schedule object. :rtype: Schedule r"Nr schedule_typeminutesrepeatsnext_runcronrintended_date_kwarg)r"z-A schedule with the same name already exists.) r"r#rr$r%rBrCrDrFrGrrH) r+r ONCErr0objectsfilterexistsr full_cleanr) r#r$r%r"rrBrCrDrFrGrrHss r>schedulerOQs& ::fd #D ::fd #DJJ >MjjD)GjjB'Gzz*hlln5H ::fd #DjjD)G **%:DA   ''T'299;;LMM     # / ALLNFFH Hr@cU(a [X5$[5n[R"U5nUbU$[5U- S-Us=:aS:ag [ S5 MF)a Return the result of the named task. :type task_id: str or uuid :param task_id: the task name or uuid :type wait: int :param wait: number of milliseconds to wait for a result :param bool cached: run this against the cache backend :return: the result object of this task :rtype: object Nr{Gz?) result_cachedrr get_resultr)task_idwaitrstartrs r>resultrYs`W++ FE  OOG $ =H FUNd "d /a /  0 d r@Nc$U(d [5n[5nURRURSU35nU(a[ R "U5S$[5U- S-Us=:aS:ag [S5 Mu)z* Return the result from the cache backend :rYrQrrRN)rrcacher,r6rloadsr)rUrVrrWrXs r>rSrSs  FE  LL  0'; <  &&q)(3 3 FUNd "d /a /  0 d r@FcfU(a [XX#5$[5nU(aC[U5U:Xd%U(a[5U- S-Us=:aS:aO OO [S5 MB[R "X5nU(aU$[5U- S-Us=:aS:ag [S5 MJ)a Return a list of results for a task group. :param str group_id: the group id :param bool failures: set to True to include failures :param int count: Block until there are this many results in the group :param bool cached: run this against the cache backend :return: list or results rQrrRN)result_group_cachedr count_grouprr get_result_groupgroup_idfailuresrVcountrrWrXs r> result_grouprfs"8tCC FE H%.Ve^t+t8q8 $K   ! !( 5 H FUNd "d /a /  0 d r@cNU(d [5n[5nU(aC[U5U:Xd%U(a[5U- S-Us=:aS:aO OO [S5 MBURR UR SUS35nU(ac/nUHYn[R"URR U55n U S(d U(dMEURU S5 M[ U$[5U- S-Us=:aS:ag [S5 M) zB Return a list of results for a task group from the cache backend rQrrRr[:keyssuccessrYN) rrcount_group_cachedrr\r,r6rr]append) rcrdrVrerrW group_list result_listtask_keyr)s r>r_r_s  FE "8,5Ve^t+t7a7 $K \\%%(98*E&JK K&$**6<<+;+;H+EF ?hh&&tH~6'  FUNd "d /a /  0 d  r@cU(a [X5$[5n[R"U5nU(aU$[5U- S-Us=:aS:ag [ S5 MJ)a  Return the processed task. :param task_id: the task name or uuid :type task_id: str or uuid :param wait: the number of milliseconds to wait for a result :type wait: int :param bool cached: run this against the cache backend :return: the full task object :rtype: Task rQrrRN) fetch_cachedrr get_taskr)rUrVrrWts r>fetchrss^G** FE  MM' " H FUNd "d /a /  0 d r@cU(d [5n[5nURRURSU35nU(ab[ R "U5n[USUSUSURS5USUSURS5US US US US S 9 $[5U- S-Us=:aS:ag [S5 M)z2 Return the processed task from the cache backend r[r!r"r#rr$r%rr&stoppedrYri) r!r"r#rr$r%rr&rurYrirQrrRN) rrr\r,r6rr]r r)rUrVrrWrXr)s r>rprps  FE  LL  0'; <  &&q)D:&\&\XXf%&\H~+YYH~Y   FUNd "d /a /  0 d ' r@TcfU(a [XX#5$[5nU(aC[U5U:Xd%U(a[5U- S-Us=:aS:aO OO [S5 MB[R "X5nU(aU$[5U- S-Us=:aS:ag [S5 MJ)z Return a list of Tasks for a task group. :param str group_id: the group id :param bool failures: set to False to exclude failures :param bool cached: run this against the cache backend :return: list of Tasks rQrrRN)fetch_group_cachedrr`rr get_task_grouprbs r> fetch_groupry!s!(dBB FE H%.Ve^t+t8q8 $K     3 H FUNd "d /a /  0 d r@cU(d [5n[5nU(aC[U5U:Xd%U(a[5U- S-Us=:aS:aO OO [S5 MBURR UR SUS35nU(a/nUHn[R"URR U55n U S(d U(dME[U SU SU S U R S 5U S U S U R S 5U SU SU SU R S5U SS9 n URU 5 M U$[5U- S-Us=:aS:ag [S5 GM)z> Return a list of Tasks for a task group in the cache backend rQrrRr[rhrir!r"r#rr$r%rr&rurYr) r!r"r#rr$r%rr&rurYrriN) rrrjrr\r,r6rr]r rk) rcrdrVrerrWrl task_listrnr)rrs r>rwrw?sj  FE "8,5Ve^t+t8q8 $K \\%%(98*E&JK I&$**6<<+;+;H+EF ?hh:!&\!&\!XXf-!&\#H~ $ 3 $Y $Y#H~"hhw/ $Y A$$Q'#'$  FUNd "d /a /  0 d 3 r@cRU(a [X5$[R"X5$)z Count the results in a group. :param str group_id: the group id :param bool failures: Returns failure count if True :param bool cached: run this against the cache backend :return: the number of tasks/results in a group :rtype: int )rjr get_group_count)rcrdrs r>r`r`ks#!(55    33r@cHU(d [5nURRURSUS35nU(a_U(d [ U5$SnUHCn[ R "URRU55nUS(aM>US- nME U$g)z3 Count the results in a group in the cache backend r[rhrrirN)rr\r,r6lenrr])rcrdrrl failure_countrnr)s r>rjrjzs !!V__$5Qxj"FGJz? " "H &&v||'7'7'ABD ??" #r@cRU(a [U5$[R"X5$)z Delete a group. :param str group_id: the group id :param bool tasks: If set to True this will also delete the group tasks. Otherwise just the group label is removed. :param bool cached: run this against the cache backend :return: )delete_group_cachedr delete_group)rctasksrs r>rrs#"8,,   X --r@cU(d [5nURSUS3nURRU5nURR U5 URR U5 g)z' Delete a group from the cache backend r[rhN)rr6r\r, delete_manydelete)rcr group_keyrls r>rrs] ??#1XJe4I!!),J LLZ( LL "r@cxU(d [5nURRURSU35$)z& Delete a task from the cache backend r[)rr\rr6)rUrs r> delete_cachedrs3  <<  &//!2!G9= >>r@cDU(d [5nUR5$)z Returns the current queue size. Note that this doesn't count any tasks currently being processed by workers. :param broker: optional broker :return: current queue size :rtype: int )r queue_size)rs r>rrs     r@c [U5n[5SnURSU5nURSS5 URS[ 55US'XES'X5S'URSS5(aUSUS 'S US'USnUR R URS US 3[R"U55 UH*n[U[5(dU4n[U/UQ70UD6 M, U$) z- enqueues a function with iterable arguments rrrNrrrrrTr[z:args) rr r,r+rr\setr6rr2 isinstancetupler?)r# args_iterr%r iter_groupoptionsrr$s r> async_iterrsYJJjjf-G KK Hjl;GH!G&L{{8T""!(!2 GH X F LL ?? 1ZL. 0C0CI0N$&&7D4*$*'* r@cBU(d [5SnSn0nURS5n[U5[LaU4n[ U5S:aUSn[ U5S:aUSnXS'XS'X&S'X6S'U=(d [ 5US '[ US/UQ70UD6 U$) zk enqueues a chain of tasks the chain must be in the format [(func,(args),{kwargs}),(func,(args),{kwargs})] rrrrrrr)r r+typerrrr?)rrrrrr$r%r)s r> async_chainrs q  D F 99Q__init__ Iter.__init__sE JB l ,     r@cURRU5 UR(aSUlUR5$)z add arguments to the set F)r$rkr&length)rr$s r>rk Iter.append s0  << DL{{}r@cURURS'URURS'URURS'[ UR UR 40URD6UlSUlUR$)zE Start queueing the tasks to the worker cluster :return: the task id rrrT) rr%rrrr#r$r!r&rs r>runIter.runsi !%  H"ii F $  HTYY AT[[A wwr@cbUR(a[URXRS9$g)z return the full list of results. :param int wait: how many milliseconds to wait for a result :return: an unsorted list of results rVrNr&rYr!rrrVs r>rY Iter.results% <<$''[[A A r@cbUR(a[URXRS9$g)z get the task result objects. :param int wait: how many milliseconds to wait for a result :return: an unsorted list of task objects rNr&rsr!rrs r>rs Iter.fetch's% <<tKK@ @ r@c,[UR5$)zO get the length of the arguments list :return int: length of the argument list )rr$rs r>r Iter.length0s 499~r@)r$rrr#r!r%r&rr)__name__ __module__ __qualname____firstlineno____doc__r r-r.rrkrrYrsr__static_attributes__rr@r>rrsC  {{ YY$ BAr@rc\rSrSrSrSS\R \RS4SjrSr Sr S Sjr S Sjr S r S rS rg)Chaini8z A sequential chain of tasks NcU=(d /UlU=(d SUlU=(d [5UlX0lX@lSUlgr)rrrrrrr&)rrrrrrs r>rChain.__init__=s9 [b ,     r@cURRXU45 UR(a[UR5 SUlUR 5$)zC add a task to the chain takes the same parameters as async_task() F)rrkr&rrrrr#r$r%s r>rk Chain.appendGsA 4v./ <<  $ DL{{}r@c[URSSURURURUR S9UlSUlUR$)zN Start queueing the chain to the worker cluster :return: the chain's group id N)rrrrrT)rrrrrrr&rs r>r Chain.runSsJ !**Q-**;;;;    zzr@cUR(a-[URXR5URS9$g)z return the full list of results from the chain when it finishes. blocks until timeout. :param int wait: how many milliseconds to wait for a result :return: an unsorted list of results )rVrerN)r&rfrrrrs r>rY Chain.resultbs2 << [[]4;;  r@cUR(a/[URUUUR5URS9$g)z get the task result objects from the chain when it finishes. blocks until timeout. :param failures: include failed tasks :param int wait: how many milliseconds to wait for a result :return: an unsorted list of task objects rdrVrerN)r&ryrrr)rrdrVs r>rs Chain.fetchns: << !kkm{{   r@cbUR(dg[URURS9$)zY get the index of the currently executing chain element :return int: current chain index N)r)r&r`rrrs r>current Chain.currents# ||4::dkk::r@c,[UR5$)z> get the length of the chain :return int: length of the chain )rrrs r>r Chain.lengths 4::r@)rrrrr&rr)Tr)rrrrrr r-r.rrkrrYrsrrrrr@r>rr8s@ T[[tyyQU   ";r@rc\rSrSrSrSr\S5r\RS5r\S5r \ RS5r \S5r \ RS 5r \S 5r \ RS 5r \S 5r \ RS 5r \S5r \ RS5r SrSSjrSrSSjrSSjrSSjrSSjrSrg) AsyncTaskiz an async task cDSUlSUlXlX lX0lgr)r!r&r#r$r%rs r>rAsyncTask.__init__s    r@c&URSS5$Nr _get_optionrs r>rAsyncTask.brokers$//r@c(URSU5 gr _set_optionrvalues r>rr 5)r@c&URSS5$Nrrrs r>rAsyncTask.sync--r@c(URSU5 grrrs r>rr 'r@c&URSS5$Nrrrs r>rAsyncTask.saverr@c(URSU5 grrrs r>rrrr@c&URSS5$Nrrrs r>rAsyncTask.hookrr@c(URSU5 grrrs r>rrrr@c&URSS5$Nrrrs r>rAsyncTask.groups..r@c(URSU5 grrrs r>rrs %(r@cBURS[R5$Nr)rr r-rs r>rAsyncTask.cacheds$++66r@c(URSU5 grrrs r>rrrr@crSUR;aX RSU'OX RU'SUlg)NrF)r%r&)rr;rs r>rAsyncTask._set_options2 $++ %,1KK $S )$KK  r@NcSUR;aURSRX5$URRX5$)Nr)r%r,)rr;defaults r>rAsyncTask._get_options; $++ %;;{+//= =;;??30 0r@c[UR/URQ70URD6UlSUlUR$)NT)r?r#r$r%r!r&rs r>r AsyncTask.runs4TYYBBdkkB wwr@cbUR(a[URXRS9$gNrrrs r>rYAsyncTask.results# <<$''[[A A r@cbUR(a[URXRS9$grrrs r>rsAsyncTask.fetchs# <<tKK@ @ r@cUR(a3UR(a![URUUUURS9$ggNr)r&rrfrrrdrVres r>rfAsyncTask.result_groups: <ryAsyncTask.fetch_groups: <rrs900 ]]**.. [[((.. [[((.. [[((// \\))77 ]]**1  BAr@rcSSKJn SSKJn [ 5n[ 5n[ R "U5nURU5 URS5 U"X4[SS55 URS5 U"U5 UR5 UR5 UR5 UR5 US$)z2Simulate a package travelling through the cluster.r)monitor)workerSTOPfrEr!) django_q.monitorrdjango_q.workerr rrr]putrclose join_thread)r<rr  task_queue result_queuer)s r>r3r3s(&J7L   t $DNN4NN6 :U3^4V L :r@)rN)FrNN)TrNN)FNr)1rmultiprocessingrrr django.dbr django.utilsrdjango_q.brokersr django_q.confr r django_q.humanhashr django_q.modelsr r django_q.queuesrdjango_q.signalsrdjango_q.signingrr?rOr-rYrSrfr_rsrpryrwr`rjrrrrrr.rrrrr3rr@r>rs""%!(&#*!(*9x3 l4;;0  %*dkk><$++0:$(atDKK<)X$) 4$"'t{{ . #? 6"$++DIId2CCLUUphhVr@