`fdZddlZddlmZmZddlmZddlmZddl m Z ddl m Z m Z ddlmZdd lmZmZmZdd lmZmZmZmZmZdd lmZdd lmZmZdd lm Z ddl!m"Z"m#Z#ddl$m%Z%ddl&m'Z'ddl(m)Z)ddl*m+Z,ddl-m.Z.ddl/m0Z0dZ1e"dddddddddd d!d" Z2d#Z3d$Z4d%Z5e6Z7d-d'Z8d.d(Z9Gd)d*Z:e j;j<Gd+d,Z=e=Z>dS)/z=Task implementation: request context and the task base class.N) ExceptionInfoExceptionWithTraceback) serialization)OperationalError)uuid) current_appstates) _task_stack)_chaingroup signature)IgnoreImproperlyConfiguredMaxRetriesExceededErrorRejectRetry)class_property) EagerResultdenied_join_result)abstract) mattrgetter maybe_list) instantiate) gethostname)raise_with_context) resolve_all)_unpickle_task_v2)appstr)ContextTaskqueue routing_keyexchangepriorityexpires serializer delivery_mode compression time_limitsoft_time_limit immediate mandatoryz$zz!<@task: {0.name} of {app}{flags}>cZ|r(dd|S|S)Nz ({})z, )formatjoin)flagsdefaults A/var/www/html/env/lib/python3.11/site-packages/celery/app/task.py _strflagsr5+s- 0~~dii../// Nc|t|ng}|jr|dnd|s|jrtnt }||t||jrt|jndS)Nz v2 compatible)r2app) list __v2_compat__append_app R_BOUND_TASKR_UNBOUND_TASKr0r5r)taskfmtr2s r4 _reprtaskrA1s ,DKKK"E%)%7AELL!!!T <"i;ll^ :: Ie$$!% 4F49      r6ceZdZdZdZdZdZdZdZdZ dZ dZ dZ dZ dZdZdZdZdZdZdZdZdZdZdZdZdZdZdZdZdZdZdZ dZ!dZ"dZ#dZ$dZ%dZ&dZ'dZ(dZ)d Z*dd Z+d Z,d Z-e.d Z/dS)r z&Task request variables (Task.request).NrTFcV|j|i||j|j|i||_dSdSN)updateheaders_get_custom_headersselfargskwargss r4__init__zContext.__init__csF T$V$$$ < 343TDVDDDLLL r6ci}|j|i|htjddddd}|D]}||d|sdS|S)Nlangr?argsrepr kwargsreprr))rEr __dict__keyspop)rIrJrKrF celery_keyskeys r4rGzContext._get_custom_headershs''''i(--//iiii\i[hi  # #C KKT " " " " 4r6c&|jj|i|SrD)rQrErHs r4rEzContext.updaters#t}#T4V444r6c4|jSrD)rQclearrIs r4rXz Context.clearus}""$$$r6c$t|||SrD)getattr)rIrUr3s r4getz Context.getxstS'***r6c(dt|dS)Nz )varsrYs r4__repr__zContext.__repr__{s+DJJ++++r6c|jpd\}}id|jd|jd|jd|jd|jd|jd|jd |jd |j d |j d |j d |d|d|j d|j d|jd|jd|ji}t#|drLt#|dr<|j5|j.|j|d<|jD] \}}|||< |S)NNNtask_idroot_id parent_idgroup_id group_indexshadowchordchainlink link_errorr&r+r*rFretriesreply_toreplaced_task_nestingoriginstampsstamped_headers) timelimitidrdrer rgrhrirj callbackserrbacksr&rFrmrnrorphasattrrqrritems)rI limit_hard limit_softexecution_optionskvs r4as_execution_optionszContext.as_execution_options~s!%!?< J tw t|      4+  dk   TZ  TZ  DN  $-  t|  z  *  t|  t|  ! " $T%?# $ dk%  ( 4 " " -wt5F'G'G -{&4+?+K7;7K!"34 K--//--DAq+,%a((  r6c,|jg|_|jSrD) _childrenrYs r4childrenzContext.childrens > !DN~r6rD)0__name__ __module__ __qualname____doc__r _protectedrJrucalled_directlyrjricorrelation_id delivery_inforvetar&r rgrFhostnamert ignore_resultis_eagerrKlogfileloglevelrpre propertiesrmrnrordrhtasksetrsutcrrrqrLrGrErXr\r`r~propertyrr6r4r r <sV00IJ DIO E ENMH CG EKGH BMH FGH FIJGHG FGI CO FEEE 555%%%++++,,,!!!:Xr6r cxeZdZdZdZdZeZeZdZdZ dZ dZ dZ dZ dZdZdZdZdZdZdZdZdZdZdZdZdZdZd ZdZdZd ZdZ dZ!dZ"dZ#dZ$d Z%dZ&e'd Z(e'd Z)e'dZ*e+e*e(Z,e'dZ-e'dZ.dZ/dZ0dZ1dZ2dZ3 d5dZ4dZ5 d6dZ6e6Z7 d7dZ8 d8dZ9dZ:d9dZ;e;ZdZ?d Z@d!ZAd:d"ZBd#ZCd;d$ZDd>#&&-NN3qrr7E2222Ce,,,,  - - -r6ct||}t|ddr|j}||}||_t|||dS)N __wrapped__)r[rr)rattraroundorigmeths r4rzTask.add_aroundsZsD!! 4 - - $#Dvd||T4     r6ctj|||| |j|i||tjS#|tjwxYw)N)rJrK)r push push_requestrun pop_requestrSrHs r4__call__z Task.__call__s tF333 48T,V,,       O           O    s A!!)B ctt|j}|r|tjvr|nd}t|j|fdfSrD)typersysmodulesrname)rImods r4 __reduce__zTask.__reduce__s@ 4jj#9SCK//ccT!DIs#3T::r6c td)z)The body of the task executed by workers.z!Tasks must define the run method.)NotImplementedErrorrHs r4rzTask.runs!"EFFFr6c ,t|j|||fi|SrD)rStrategy)rIr8consumerrKs r4start_strategyzTask.start_strategys 4=$XHHHHHr6c.|||S)ahStar argument version of :meth:`apply_async`. Does not support the extra options enabled by :meth:`apply_async`. Arguments: *args (Any): Positional arguments passed on to the task. **kwargs (Any): Keyword arguments passed on to the task. Returns: celery.result.AsyncResult: Future promise. ) apply_asyncrHs r4delayz Task.delaysf---r6c |jr% |j} | |pdi|pin#t$rYnwxYw|jr#|p|||||}n|p||||}|} |r t | fi|n| }|d|j|j r|d|j | } | j j r| |5} |d} | | jr| j} n | j j} ||f}t#j|| \}}}t#j||||g\}}dddn #1swxYwYt)5|j||f|p t-||d|cdddS#1swxYwYdS| j|j||f|||||j||d|S) aApply tasks asynchronously by sending a message. Arguments: args (Tuple): The positional arguments to pass on to the task. kwargs (Dict): The keyword arguments to pass on to the task. countdown (float): Number of seconds into the future that the task should execute. Defaults to immediate execution. eta (~datetime.datetime): Absolute time and date of when the task should be executed. May not be specified if `countdown` is also supplied. expires (float, ~datetime.datetime): Datetime or seconds in the future for the task should expire. The task won't be executed after the expiration time. shadow (str): Override task name used in logs/monitoring. Default is retrieved from :meth:`shadow_name`. connection (kombu.Connection): Re-use existing broker connection instead of acquiring one from the connection pool. retry (bool): If enabled sending of the task message will be retried in the event of connection loss or failure. Default is taken from the :setting:`task_publish_retry` setting. Note that you need to handle the producer/connection manually for this to work. retry_policy (Mapping): Override the retry policy used. See the :setting:`task_publish_retry_policy` setting. time_limit (int): If set, overrides the default time limit. soft_time_limit (int): If set, overrides the default soft time limit. queue (str, kombu.Queue): The queue to route the task to. This must be a key present in :setting:`task_queues`, or :setting:`task_create_missing_queues` must be enabled. See :ref:`guide-routing` for more information. exchange (str, kombu.Exchange): Named custom exchange to send the task to. Usually not used in combination with the ``queue`` argument. routing_key (str): Custom routing key used to route the task to a worker server. If in combination with a ``queue`` argument only used to specify custom routing keys to topic exchanges. priority (int): The task priority, a number between 0 and 9. Defaults to the :attr:`priority` attribute. serializer (str): Serialization method to use. Can be `pickle`, `json`, `yaml`, `msgpack` or any custom serialization method that's been registered with :mod:`kombu.serialization.registry`. Defaults to the :attr:`serializer` attribute. compression (str): Optional compression method to use. Can be one of ``zlib``, ``bzip2``, or any custom compression methods registered with :func:`kombu.compression.register`. Defaults to the :setting:`task_compression` setting. link (Signature): A single, or a list of tasks signatures to apply if the task returns successfully. link_error (Signature): A single, or a list of task signatures to apply if an error occurs while executing the task. producer (kombu.Producer): custom producer to use when publishing the task. add_to_parent (bool): If set to True (default) and the task is applied while executing another task, then the result will be appended to the parent tasks ``request.children`` attribute. Trailing can also be disabled by default using the :attr:`trail` attribute ignore_result (bool): If set to `False` (default) the result of a task will be stored in the backend. If set to `True` the result will not be stored. This can also be set using the :attr:`ignore_result` in the `app.task` decorator. publisher (kombu.Producer): Deprecated alias to ``producer``. headers (Dict): Message headers to be included in the message. Returns: celery.result.AsyncResult: Promise of future evaluation. Raises: TypeError: If not enough arguments are passed, or too many arguments are passed. Note that signature checks may be disabled by specifying ``@task(typing=False)``. kombu.exceptions.OperationalError: If a connection to the transport cannot be made, or if the connection is lost. Note: Also supports all keyword arguments supported by :meth:`kombu.Producer.publish`. rrr%r'N)accept)rcrkrl)rcproducerrkrl result_clsrh task_type)r __header__AttributeErrorr: shadow_name_get_exec_optionsdict setdefaultrr%rrtask_always_eagerproducer_or_acquirer\r'rrdumpsloadsrapplyr send_taskr AsyncResult)rIrJrKrcrrkrlrhoptionscheck_argumentspreoptsr8eager_producerr'body content_typecontent_encodingdatas r4rzTask.apply_asyncs/V ; A A"&/ $*"@&,B@@@@"       GNt//fgNNFFFt//fgFFF((**.5B$w**'***7?D,>??? = :   z4= 9 9 9mmoo 8 % ((22 n$[[66 %%0>%3%> %(X%= V|7D7J*884 . -2,(8(>    f               $%% O O!tz$O8I466'+ OOFMOO O O O O O O O O O O O O O O O O O O!3= 4188jT=M  s1 **A,E??FF!GG  G cdS)aOverride for custom task name in worker logs/monitoring. Example: .. code-block:: python from celery.utils.imports import qualname def shadow_name(task, args, kwargs, options): return qualname(args[0]) @app.task(shadow_name=shadow_name, serializer='pickle') def apply_function_async(fun, *args, **kwargs): return fun(*args, **kwargs) Arguments: args (Tuple): Task positional arguments. kwargs (Dict): Task keyword arguments. options (Dict): Task execution options. Nr)rIrJrKrs r4rzTask.shadow_nameYrr6c ||jn|}||jn|}||jn|}i||}|jpi}|d}|||d<|r||d<nM|d} |d} | dkr| r| |d<n|||j|||fd|i|S)Nr%r"r$r#r.r)requestrJrKr~rr\rEr ) rIrrJrKr" extra_optionsrrr%r$r#s r4signature_from_requestzTask.signature_from_requestns")/$,,w#|w||#)>vEW1133E}E-3  $$Z00  "*GJ   .$GG  $((44H'++M::K2~~+~#.  }---t~ &'  (, 0=   r6c f|j} | jdz} |||_||jn|}| jrt |pt dd|s ||j}| j} |j | ||f||| d|} |c| |kr]|rt || d |j | j | j| j| j| jt ||p|| | } | r|r| | S | n##t"$r}t%|d d}~wwxYw|r| | S) a Retry the task, adding it to the back of the queue. Example: >>> from imaginary_twitter_lib import Twitter >>> from proj.celery import app >>> @app.task(bind=True) ... def tweet(self, auth, message): ... twitter = Twitter(oauth=auth) ... try: ... twitter.post_status_update(message) ... except twitter.FailWhale as exc: ... # Retry in 5 minutes. ... raise self.retry(countdown=60 * 5, exc=exc) Note: Although the task will never return above as `retry` raises an exception to notify the worker, we use `raise` in front of the retry to convey that the rest of the block won't be executed. Arguments: args (Tuple): Positional arguments to retry with. kwargs (Dict): Keyword arguments to retry with. exc (Exception): Custom exception to report when the max retry limit has been exceeded (default: :exc:`~@MaxRetriesExceededError`). If this argument is set and retry is called while an exception was raised (``sys.exc_info()`` is set) it will attempt to re-raise the current exception. If no exception was raised it will raise the ``exc`` argument provided. countdown (float): Time in seconds to delay the retry for. eta (~datetime.datetime): Explicit time and date to run the retry at. max_retries (int): If set, overrides the default retry limit for this execution. Changes to this parameter don't propagate to subsequent task retry attempts. A value of :const:`None`, means "use the default", so if you want infinite retries you'd have to set the :attr:`max_retries` attribute of the task to :const:`None` first. time_limit (int): If set, overrides the default time limit. soft_time_limit (int): If set, overrides the default soft time limit. throw (bool): If this is :const:`False`, don't raise the :exc:`~@Retry` exception, that tells the worker to mark the task as being retried. Note that this means the task will be marked as failed if the task raises an exception, or successful if it returns after the retry call. **options (Any): Extra options to pass on to :meth:`apply_async`. Raises: celery.exceptions.Retry: To tell the worker that the task has been re-sent for retry. This always happens, unless the `throw` keyword argument has been explicitly set to :const:`False`, and is considered normal operation. rNzTask can be retried) countdownrrmz$Can't retry {}[{}] args:{} kwargs:{}) task_args task_kwargs)excwhenrsigF)requeue)rrmoverride_max_retries max_retriesrrrdefault_retry_delayrrrr0rrtrJrKr Exceptionr)rIrJrKrthrowrrr rrrmrSrets r4retryz Task.retrys|,/A%  "(3D %*5*=d&&;   " J sHe,A4&H&H I I I 1y(0I# 'D ' T6 S'      "w'<'< (#3'''..6==Iwz1618V/  #"2X1MMM    J - MMOOOO - - -e,,, , -  I s5D D*D%%D*c   ddlm} |} |pd}|pi}|p t}|pd}| | jj}| j|j}||j|d|| pdtt|t|| ddd d d  d d d }d vr/t d |d < fd|d D|d<d}| |j|d||}|||||}|j }t|tr*|j|j}}t|t r|j}t|t$r%|j|j|dzS|j t,jn |jj}t3|||||jS)aExecute this task locally, by blocking until the task returns. Arguments: args (Tuple): positional arguments passed on to the task. kwargs (Dict): keyword arguments passed on to the task. throw (bool): Re-raise task exceptions. Defaults to the :setting:`task_eager_propagates` setting. Returns: celery.result.EagerResult: pre-evaluated result. r) build_tracerrNTrFr$r#r%)rr$r#r%) rtr?rmrrrrrurvrFrrrrc Xi|]&}|t|g'Sr)rr\).0headerrs r4 zTask.apply..*s>!!!@F 7;;vr#:#:;;!!!r6rq)eager propagater8r)rm) tracebackr)celery.app.tracerrrrtask_eager_propagates_tasksrrrr\retval isinstancer exceptionrrrrrrinfor SUCCESSstater)rIrJrKrkrlrcrmrrrrFrrr8r?rtbtracerrrr#s ` r4rz Task.applysI 211111mmoozr2#TVV,Q =H2Ez$)$I A# #D))":..$[[%@@ #KK 33&{{=99#KK 33   &  ' ')3GsF +t}}*7JDL59YJJBHJJ Jr6cZ|d|jt||g|Ri|S)zCreate signature. Returns: :class:`~celery.signature`: object for this task, wrapping arguments and execution options for a single task invocation. r8)rr8r )rIrJstarargs starkwargss r4r zTask.signatureGs< eTX...t=h===*===r6c.|||S)zUCreate signature. Shortcut for ``.s(*a, **k) -> .signature(a, k)``. r rHs r4szTask.sSs ~~dF+++r6c2|||dS)zpCreate immutable signature. Shortcut for ``.si(*a, **k) -> .signature(a, k, immutable=True)``. T) immutabler-rHs r4sizTask.siZs ~~dFd~;;;r6cZddlm}|||||jS)z;Create a :class:`~celery.canvas.chunks` task for this task.r)chunksr8)celeryr3r.r8)rIitnr3s r4r3z Task.chunksas7!!!!!!vdffhhA484444r6cXddlm}||||jS)z7Create a :class:`~celery.canvas.xmap` task from ``it``.r)xmapr4)r5r9r.r8)rIr6r9s r4mapzTask.mapfs5tDFFHHbdh////r6cXddlm}||||jS)z;Create a :class:`~celery.canvas.xstarmap` task from ``it``.r)xstarmapr4)r5r<r.r8)rIr6r<s r4starmapz Task.starmapks5######x"$(3333r6c |j}||jjj}|jj|j5}|j|f|j||d|cdddS#1swxYwYdS)aSend monitoring event message. This can be used to add custom event types in :pypi:`Flower` and other monitors. Arguments: type_ (str): Type of event, e.g. ``"task-failed"``. Keyword Arguments: retry (bool): Retry sending the message if the connection is lost. Default is taken from the :setting:`task_publish_retry` setting. retry_policy (Mapping): Retry settings. Default is taken from the :setting:`task_publish_retry_policy` setting. **fields (Any): Map containing information about the event. Must be JSON serializable. N)r)rr retry_policy) rr8rtask_publish_retry_policyeventsdefault_dispatcherrsendrt)rItype_rr?fieldsreqrs r4 send_eventzTask.send_eventps$l  8=BL X_ / / / F F O!16OV5|OOGMOO O O O O O O O O O O O O O O O O O OsA$$A(+A(c|jj}d|jvrtdt |t r t |ddstdt |tr)||jj d dz}t|jj pgD]}| |t|jjpgD]}||t |t r\d |jvrS|j d jd g}|t|jd ||jj|jd dd z}|||jj|jj|jj| t |t r/t|j pgD]}||t1|jjpgD]3}t5||j}||||z}4||S)aKReplace this task, with a new task inheriting the task id. Execution of the host task ends immediately and no subsequent statements will be run. .. versionadded:: 4.0 Arguments: sig (Signature): signature to replace with. visitor (StampingVisitor): Visitor API object. Raises: ~@Ignore: This is always raised when called in asynchronous context. It is best to always use ``return self.replace(...)`` to convey to the reader that the task won't continue after being replaced. riz8A signature replacing a task must not be part of a chordtasksTz"Cannot replace with an empty chainzcelery.accumulater)indexrkror)rirfrgrdro)ror4)rrirrrr r[r r8rIr.rrurkrvrlrextendfreezertr\setrgrdreversedrjr on_replace) rIrricallbackerrbackfinal_task_linksro chain_taskts r4replacez Task.replaces" " ck ! !&J  c6 " " M73+F+F M&'KLL L c5 ! ! B 48>"5688q8AA AC"4<#9::@b  H HHX    !$,"788>B $ $G NN7 # # # # c6 " " Ev'<'<"y}4??KK   # #Js{6/B$C$C D D D 4 > > >G,,,<<<555 000 444 OOOO4B$B$B$H00000 B B B B                 111$ :::!!!+++   h|$$G""" X  ^^''X'''r6r!)r.rb)?rrbilliard.einforrkomburkombu.exceptionsrkombu.utils.uuidrr5rr celery._stater celery.canvasr r r celery.exceptionsrrrrr celery.localr celery.resultrr celery.utilsrcelery.utils.functionalrrcelery.utils.importsrcelery.utils.nodenamesrcelery.utils.serializationrrrrregistryrutilsr__all__rzr=r>rtrTaskTyper5rAr CallableTaskregisterr!BaseTaskrr6r4rsCC @@@@@@@@------!!!!!!&&&&&&&&%%%%%%2222222222bbbbbbbbbbbbbb''''''99999999!!!!!!;;;;;;;;,,,,,,......999999??????'''''' #{ ]J I/=,{K6 0 0   ddddddddN ['['['['['['[' ['| r6