o wvXj$@sdZddlmZmZddlmZddlmZddlm Z ddlm Z ddlm Z ddl mZmZdd lmZmZmZdd lmZdd lmZd Zd ZeGdddeZGdddeZeeeGddde Z Gddde ZddZddZ dS)zDeprecated task base class. The task implementation has been moved to :mod:`celery.app.task`. This contains the backward compatible Task class used in the old API, and shouldn't be used in new applications. )absolute_importunicode_literals)Exchange) current_app)Context)Task _reprtask)python_2_unicode_compatiblewith_metaclass)Proxyclass_property reclassmethod)maybe_schedule)get_task_logger)rrTaskType PeriodicTasktask) delay apply_asyncretryapplysubtask_from_requestsignature_from_request signature AsyncResultsubtask _get_request_get_exec_optionsc@s,eZdZddZddZddZddZd S) _CompatSharedcCs||_||_dSN)namecons)selfr!r"r$M/var/www/html/myproject/venv/lib/python3.10/site-packages/celery/task/base.py__init__#s z_CompatShared.__init__cC t|jSr )hashr!r#r$r$r%__hash__' z_CompatShared.__hash__cCs d|jfS)Nz )r!r)r$r$r%__repr__*s z_CompatShared.__repr__cCs ||Sr )r")r#appr$r$r%__call__-r+z_CompatShared.__call__N)__name__ __module__ __qualname__r&r*r,r.r$r$r$r%r s  rcs,eZdZdZiZfddZddZZS)raMeta class for tasks. Automatically registers the task in the task registry (except if the :attr:`Task.abstract`` attribute is set). If no :attr:`Task.name` attribute is provided, then the name is generated from the module and class name. csNttj}dp d}dd}|sdds"|Sddp-dd}t|tsK|durKD] }t|ddrF|j}nq9t }|d<d} | s`| |d<} d sd d l m } d |g} | jvrd j| <| t| fdd|j} | | vr| || | } | || jS)Nr0__main__abstract autoregisterT_appr-r! _decoratedr)connect_on_app_finalize.c stt|dS)N)r5)r__new__dict)r-attrsbasesclsr!r$r%js z"TaskType.__new__..)superrr:getpop isinstancer getattrr5r_get_current_object gen_task_name celery._stater7join_creation_countr_tasksregisterbind __class__)r?r!r>r=new task_moduler3r-base task_namer7 unique_nametasksinstancerNr<r%r:=s@          zTaskType.__new__cCst|Sr rr)r$r$r%r,zszTaskType.__repr__)r/r0r1__doc__rJr:r, __classcell__r$r$rVr%r1s  =rc@seZdZdZdZdZdZdZdZdZ dZ dZ dZ dZ dZdZejdZeD] Zeeeeee<q%eddZed d Zejd d Zed d ZeddZ  dddZedddZdS)rzbDeprecated Task base class. Modern applications should use :class:`celery.Task` instead. TFNregular)) exchange_typetask_default_exchange_type) delivery_modetask_default_delivery_modecCs|Sr )rr)r$r$r%requestsz Task.requestcCs|jdur |jjS|jSr )_backendr-backendr)r$r$r%r`s z Task.backendcCs ||_dSr )r_)r?valuer$r$r%r` cKr'r )rr!)r?kwargsr$r$r% get_loggerrbzTask.get_loggercCs |S)aDeprecated method used to get a broker connection. Should be replaced with :meth:`@Celery.connection` instead, or by acquiring connections from the connection pool: Examples: >>> # using the connection pool >>> with celery.pool.acquire(block=True) as conn: ... pass >>> # establish fresh connection >>> with celery.connection_for_write() as conn: ... pass )_get_appconnection_for_write)r?r$r$r%establish_connections zTask.establish_connectioncKsX|dur|jn|}|dur|j}|p|}|jj|f|o#t|||jdd|S)a$Deprecated method to get the task publisher (now called producer). Should be replaced with :class:`kombu.Producer`: .. code-block:: python with app.connection_for_write() as conn: with app.amqp.Producer(conn) as prod: my_task.apply_async(producer=prod) or even better is to use the :class:`@amqp.producer_pool`: .. code-block:: python with app.producer_or_acquire() as prod: my_task.apply_async(producer=prod) NF)exchange routing_key auto_declare)rhrZrgreamqpProducerrri)r# connectionrhrZoptionsr$r$r% get_publishers   zTask.get_publishercKsJ|j}|p |}|dur|jr|j|jn|j}|j||fi|S)zGet consumer for the queue this task is sent to. Deprecated! Should be replaced by :class:`@amqp.TaskConsumer`. N)rerkrgqueuequeues default_queue TaskConsumer)r?rmrqrcQr$r$r% get_consumers  zTask.get_consumer)NNN)NN) r/r0r1rWr3 __bound__ __v2_compat__rprirhrZr\ mandatory immediateprioritytypeBaseTask from_config_COMPAT_CLASSMETHODSr!rrElocalsr r^r`setter classmethodrdrgrorur$r$r$r%r~s@        rcs@eZdZdZdZdZdZdZdZfddZ e ddZ Z S) rz@A task that adds itself to the :setting:`beat_schedule` setting.TFNcs4t|ds tdt|j|j|_tt|dS)N run_everyz.Periodic tasks must have a run_every attribute)hasattrNotImplementedErrorrrrelativerArr&r)rVr$r%r&s zPeriodicTask.__init__cCs,|j|jdi|jp i|jd|jj|j<dS)Nr$)rscheduleargsrcrnr)r!rrnrconf beat_schedule)r?r-r$r$r%on_boundszPeriodicTask.on_bound) r/r0r1rWr3 ignore_resultrrncompatr&rrrXr$r$rVr%rs rcOs tj|itdtifi|S)z5Deprecated decorator, please use :func:`celery.task`.rQ)rrr;r)rrcr$r$r%rs rcOstditdtifi|S)z:Deprecated decorator, please use :setting:`beat_schedule`.rQNr$)rr;r)rrnr$r$r% periodic_tasksrN)!rW __future__rrkomburceleryrcelery.app.taskrrr|r celery.fiver r celery.localr r rcelery.schedulesrcelery.utils.logr__all__r~objectrr{rrrrr$r$r$r%s,       Mr