+ S tyy ) ) +Tv>>>4>s!1AA"AAAAc2^RIHpWP,#) task_backends)rorL)r0ros& r&r-Task.get_backends#\\**r%c`VPP RVPP 2#).)r4r!r"r/s&r&rBTask.module_paths)))&&'q)?)?(@AAr%c<V^8dQh/S[RS[3,;R&S[;R&S[;R&S[;R&S[R,;R&S[;R&#) .r4rIrLrJNrK takes_context)rr intstrrbool)format __classdict__s"r& __annotate__Task.__annotate__,s^ 38 )-  -  $% r%r)r r!r"r#DEFAULT_TASK_PRIORITYrIDEFAULT_TASK_BACKEND_ALIASrLDEFAULT_TASK_QUEUE_NAMErJrKrwr1 classmethodr=rEpropertyr@rOrSrXr]rdrgrjr-rB__annotate_func__r$__classdictcell__r|s@r&rr,s*H-G-J!%I M/8 ""(( (  (  (*>E * ? + BBOr%rNrIrJrLrwFc xaaaaaa^RIHoRS9d \R4hVVVVVV3RlpV'd V!V4#V#)rmrnrKzqrun_after cannot be defined statically with the @task decorator. Use .using(run_after=...) to set it dynamically.c J<SS,P!RRVRSRSRSRS/SB#)r4rIrJrLrwr) task_class)rDrLr9rIrJrwros&r&wrappertask..wrappersSW%00   "   (     r%)rpro TypeError)functionrIrJrLrwr9rros&ddddl @r&r^r^sA f ?    x  Nr%c<a]tRt^to]R4tV3RltRtVtR#) TaskErrorc\VP4p\V4'd\V\4'g\ VP: R24hV#)z& does not reference a valid exception.)rexception_class_pathr issubclass BaseExceptionr7)r0exception_classs& r&rTaskError.exception_classsY((A(AB''z ]0 0 ,,//UV r%c2<V^8dQh/S[;R&S[;R&#)rvr traceback)ry)r{r|s"r&r}TaskError.__annotate__sNr%rN) r r!r"r#rrrr$rrs@r&rrs    r%rca]tRt^to]!RRR7tRt]R4t]R4t ]R4t Rt R t V3R lt R tVtR#) TaskResultFN)initrc\PVR\VP44\PVR\VP44R#)rUr9N)object __setattr__rrUr9r/s&r&r1TaskResult.__post_init__s84 )BC4>$+++FGr%c VP\P8Xd VP#VP\P8Xd \ R4h\ R4h)z The return value of the task. If the task didn't succeed, an exception is raised. This is to distinguish against the task returning None. z Task failedzTask has not finished yet)statusrr _return_valuerr7r/s&r& return_valueTaskResult.return_valuesM ;;*55 5%% % [[,33 3]+ +89 9r%c\VP\P\P09#r,)rrrrr/s&r& is_finishedTaskResult.is_finisheds${{/668H8S8STTTr%c,\VP4#r,)len worker_idsr/s&r&attemptsTaskResult.attemptss4??##r%c  VPP4PVP4p\F"p\ P W\W44K$ R#)z0Reload the cached task data from the task store.N)r^r-r]idTASK_REFRESH_ATTRSrrrAr0refreshed_taskattrs& r&refreshTaskResult.refreshsB..0;;DGGD&D   t7>+H I'r%c "VPP4PVP4GRjxL p\F"p\ P W\W44K$ R#L25i)z1 Reload the cached task data from the task store N)r^r-rdrrrrrArs& r&arefreshTaskResult.arefreshsP $yy446BB477KK&D   t7>+H I'Ls7A.A,3A.cB<V^8dQh/S[;R&S[;R&S[;R&S[R,;R&S[R,;R&S[R,;R&S[R,;R&S[S[,;R &S[S[S[3,;R &S[;R &S[S[,;R &S[S[,;R &S[R,;R&#)rvr^rrN enqueued_at started_at finished_atlast_attempted_atrUr9rLerrorsrr)rryrrlistr dictr)r{r|s"r&r}TaskResult.__annotate__s J G    D 4D  $& s)O cNL O!"S #&:?'r%r)r r!r"r#rrr1rrrrrrrr$rrs@r&rrsk&!&5$ ?MH : :UU$$JJor%rc<a]tRtRto]R4tV3RltRtVtR#) TaskContexti c.VPP#r,) task_resultrr/s&r&attemptTaskContext.attempts(((r%c&<V^8dQh/S[;R&#)rvr)r)r{r|s"r&r}TaskContext.__annotate__ sr%rN) r r!r"r#rrrr$rrs@r&rr s )) r%ri>rrrrrrrrr,)&collections.abcr dataclassesrrrrrinspectr r typingr asgiref.syncr r django.db.models.enumsrdjango.utils.jsonrdjango.utils.module_loadingrdjango.utils.translationr exceptionsrrrrTASK_MAX_PRIORITYTASK_MIN_PRIORITYrrrr^rrrrr%r&rs$9905.,52*&# E{E $dD1gBgB2gBT#'  '   @ $dD12$ $dD1<J<J2<J~ $dD1))2)r%