Ë
    —V.jÑ  ã                   ól   — d Z ddlZddlmZ ddlmZ ddlmZ ddlm	Z	m
Z
 dZ G d„ d	e«      Zd
„ Zdd„Zy)zRegistry of available tasks.é    N)Úimport_module)Úget_current_app)Úadd_autoretry_behaviour)ÚInvalidTaskErrorÚNotRegistered)ÚTaskRegistryc                   ó8   — e Zd ZdZeZd„ Zd„ Zd„ Zd„ Zd„ Z	d„ Z
y)	r   zMap of registered tasks.c                 ó$   — | j                  |«      ‚©N)r   )ÚselfÚkeys     úUC:\xampp\htdocs\tradingbinance\backend\.venv\Lib\site-packages\celery/app/registry.pyÚ__missing__zTaskRegistry.__missing__   s   € Ø× Ñ  Ó%Ð%ó    c                 óî   — |j                   €-t        dj                  t        |«      j                  «      «      ‚t        j                  |«      xr  |«       xs |}t        |«       || |j                   <   y)z¶Register a task in the task registry.

        The task will be automatically instantiated if not already an
        instance. Name must be configured prior to registration.
        Nz,Task class {!r} must specify .name attribute)Únamer   ÚformatÚtypeÚ__name__ÚinspectÚisclassr   )r   Útasks     r   ÚregisterzTaskRegistry.register   sg   € ð �9‰9ÐÜ"Ø>×EÑEÜ˜“J×'Ñ'ó)ó*ð *ô �‰˜tÓ$Ò/©«Ò7°4ˆÜ Ô%ØˆˆT�Y‰YŠr   c                 óz   — 	 | j                  t        |d|«      «       y# t        $ r | j                  |«      ‚w xY w)a  Unregister task by name.

        Arguments:
            name (str): name of the task to unregister, or a
                :class:`celery.app.task.Task` with a valid `name` attribute.

        Raises:
            celery.exceptions.NotRegistered: if the task is not registered.
        r   N)ÚpopÚgetattrÚKeyErrorr   )r   r   s     r   Ú
unregisterzTaskRegistry.unregister"   s<   € ð	+Ø�H‰H”W˜T 6¨4Ó0Õ1øÜò 	+Ø×$Ñ$ TÓ*Ð*ð	+ús   ‚ Ÿ:c                 ó$   — | j                  d«      S )NÚregular©Úfilter_types©r   s    r   r    zTaskRegistry.regular2   s   € Ø× Ñ  Ó+Ð+r   c                 ó$   — | j                  d«      S )NÚperiodicr!   r#   s    r   r%   zTaskRegistry.periodic5   s   € Ø× Ñ  Ó,Ð,r   c           	      óv   — | j                  «       D ��ci c]  \  }}t        |dd«      |k(  r||“Œ c}}S c c}}w )Nr   r    )Úitemsr   )r   r   r   r   s       r   r"   zTaskRegistry.filter_types8   sD   € Ø-1¯Z©Z¬\ô =©\™z˜t TÜ˜4 ¨Ó3°tÒ;ð �d‘
¨\ò =ð 	=ùó =s   ”5N)r   Ú
__module__Ú__qualname__Ú__doc__r   r   r   r   r    r%   r"   © r   r   r   r      s(   „ Ù"à!€Mò&òò+ò ,ò-ó=r   r   c                 ó0   — t        «       j                  |    S r   )r   Útasks)r   s    r   Ú_unpickle_taskr.   =   s   € ÜÓ×"Ñ" 4Ñ(Ð(r   c                 óJ   — |rt        |«       t        «       j                  |    S r   )r   r   r-   )r   Úmodules     r   Ú_unpickle_task_v2r1   A   s!   € ÙÜ�fÔÜÓ×"Ñ" 4Ñ(Ð(r   r   )r*   r   Ú	importlibr   Úcelery._stater   Úcelery.app.autoretryr   Úcelery.exceptionsr   r   Ú__all__Údictr   r.   r1   r+   r   r   Ú<module>r8      s3   ðÙ "Û Ý #å )Ý 8ß =à
€ô.=�4ô .=òb)ô)r   