File: //usr/local/lib/python3.9/site-packages/celery/utils/__pycache__/abstract.cpython-39.pyc
a
X>h: � @ sd d Z ddlmZmZ ddlmZ dZdd� ZG dd� ded �ZG d
d � d ee�Z G d d
� d
e �Z
dS )zAbstract classes.� )�ABCMeta�abstractmethod)�Callable)� CallableTask�CallableSignaturec s t � fdd�| jD ��S )Nc 3 s | ]}� |j v V qd S �N)�__dict__)�.0�B��attr� �?/usr/local/lib/python3.9/site-packages/celery/utils/abstract.py� <genexpr> � z_hasattr.<locals>.<genexpr>)�any�__mro__)�Cr r
r r �_hasattr s r c @ s* e Zd Ze� Zedd� �Zedd� �ZdS )�_AbstractClassc s$ | |u r t � fdd�| jD ��p"tS )Nc 3 s | ]}t � |�V qd S r )r )r r �r r
r r r z5_AbstractClass._subclasshook_using.<locals>.<genexpr>)�all�__required_attributes__�NotImplemented)�cls�parentr r
r r �_subclasshook_using s
��z"_AbstractClass._subclasshook_usingc C s t | ��| |� |S r )�type�register)r �otherr
r
r r s z_AbstractClass.registerN)�__name__�
__module__� __qualname__� frozensetr � classmethodr r r
r
r
r r s
r )� metaclassc @ sL e Zd ZdZeh d��Zedd� �Zedd� �Zedd� �Z e
d d
� �Z d S ) r zTask interface.> � apply_async�delay�applyc O s d S r r
��self�args�kwargsr
r
r r' $ s zCallableTask.delayc O s d S r r
r) r
r
r r& ( s zCallableTask.apply_asyncc O s d S r r
r) r
r
r r( , s zCallableTask.applyc C s | � t|�S r )r r �r r r
r
r �__subclasshook__0 s z CallableTask.__subclasshook__N) r r! r" �__doc__r# r r r' r& r( r$ r. r
r
r
r r s
r c @ s2 e Zd ZdZeh d��Zeedd� ��Zeedd� ��Z eedd� ��Z
eed d
� ��Z eed d � ��Z eed
d� ��Z
eedd� ��Zeedd� ��Zeedd� ��Zeedd� ��Zeedd� ��Zed*dd��Zed+d d ��Zed,d d ��Zed d!� �Zed"d#� �Zed$d%� �Zed&d'� �Zed(d)� �ZdS )-r zCelery Signature interface.> �__or__�clone�link�freeze�
link_error�setc C s d S r r
�r* r
r
r �name< s zCallableSignature.namec C s d S r r
r6 r
r
r r A s zCallableSignature.typec C s d S r r
r6 r
r
r �appF s zCallableSignature.appc C s d S r r
r6 r
r
r �idK s zCallableSignature.idc C s d S r r
r6 r
r
r �taskP s zCallableSignature.taskc C s d S r r
r6 r
r
r r+ U s zCallableSignature.argsc C s d S r r
r6 r
r
r r, Z s zCallableSignature.kwargsc C s d S r r
r6 r
r
r �options_ s zCallableSignature.optionsc C s d S r r
r6 r
r
r � subtask_typed s z CallableSignature.subtask_typec C s d S r r
r6 r
r
r �
chord_sizei s z CallableSignature.chord_sizec C s d S r r
r6 r
r
r � immutablen s zCallableSignature.immutableNc C s d S r r
r) r
r
r r1 s s zCallableSignature.clonec C s d S r r
)r* r9 Zgroup_idZchordZroot_idZ group_indexr
r
r r3 w s zCallableSignature.freezec K s d S r r
)r* r> r; r
r
r r5 | s zCallableSignature.setc C s d S r r
)r* �callbackr
r
r r2 � s zCallableSignature.linkc C s d S r r
)r* Zerrbackr
r
r r4 � s z CallableSignature.link_errorc C s d S r r
)r* r r
r
r r0 � s zCallableSignature.__or__c C s d S r r
r6 r
r
r �
__invert__� s z CallableSignature.__invert__c C s | � t|�S r )r r r- r
r
r r. � s z"CallableSignature.__subclasshook__)NN)NNNNN)N) r r! r" r/ r# r �propertyr r7 r r8 r9 r: r+ r, r; r< r= r> r1 r3 r5 r2 r4 r0 r@ r$ r. r
r
r
r r 5 sj �
r N) r/ �abcr r �collections.abcr �__all__r r r r r
r
r
r �<module> s