Server : LiteSpeed System : Linux barito.iixcp.rumahweb.net 5.14.0-611.49.1.el9_7.x86_64 #1 SMP PREEMPT_DYNAMIC Tue Apr 21 16:39:08 EDT 2026 x86_64 User : elvh3918 ( 1528) PHP Version : 8.2.31 Disable Function : mail Directory : /usr/local/lib/python3.9/site-packages/celery/backends/__pycache__/ |
a
��Sh� � @ s� d Z ddlmZmZ ddlmZ ddlmZ ddlm Z ddl
m Z dZ d gZ
d
Zd Ze d d
�Zdd� Zdd� ZG dd� d�Zeeedd� d�ZG dd� de �Zd S )z-Memcached and in-memory cache result backend.� )� bytes_to_str� ensure_bytes)�cached_property)�ImproperlyConfigured)�LRUCache� )�KeyValueStoreBackend)� CacheBackendNzBThe Memcached backend requires either pylibmc or python-memcached.zYThe cache backend {0!r} is unknown,
Please use one of the following backends instead: {1}i� )�limitc C sx t d d u rpdt } }zdd l}d} W n: ty` z dd l}W n tyZ tt��Y n0 Y n0 | ||ft d< t d S )Nr FT)�_impr �pylibmc� ImportError�memcacher �REQUIRES_BACKEND)�
is_pylibmcZmemcache_key_tr � r �?/usr/local/lib/python3.9/site-packages/celery/backends/cache.py�import_best_memcache s
r c s. t � \}}}|j }� |s&� fdd�}||fS )Nc s |� dd � � | i |��S )NZ behaviors)�pop)�args�kwargs�Z_Clientr r �Client2 s z!get_best_memcache.<locals>.Client)r r )r r r r �key_tr r r r �get_best_memcache+ s
r c @ sF e Zd Zdd� Zdd� Zdd� Zdd� Zd d
� Zdd d
�Zdd� Z dS )� DummyClientc O s
t | _d S �N)�_DUMMY_CLIENT_CACHE�cache)�selfr r r r r �__init__; s zDummyClient.__init__c O s | j �|�S r )r �get�r �keyr r r r r r! > s zDummyClient.getc s | j � � fdd�|D �S )Nc s i | ]}|� v r|� | �qS r r )�.0�k�r r r �
<dictcomp>C � z)DummyClient.get_multi.<locals>.<dictcomp>r& �r �keysr r& r � get_multiA s zDummyClient.get_multic O s || j |< d S r r& )r r# �valuer r r r r �setE s zDummyClient.setc O s | j �|d � d S r )r r r" r r r �deleteH s zDummyClient.deleter c C s | j �||�S r )r �incr)r r# �deltar r r r/ K s zDummyClient.incrc C s d S r r )r r# �expirer r r �touchN s zDummyClient.touchN)r )
�__name__�
__module__� __qualname__r r! r+ r- r. r/ r2 r r r r r 9 s
r c C s t tfS r )r r r r r r �<lambda>V r( r6 )r Z memcachedr Zmemoryc s� e Zd ZdZdZdZdZdZd� fdd� Zdd� Z dd � Z
d
d � Z d d
� Z � fdd�Z
dd� Zdd� Zedd� �Zd � fdd� Zdd� Z� ZS ) r zCache result backend.NTc
s� |si n|}t � j|fi |�� || _t| jjjfi |��| _|pN|pN| jjj| _ | j r~| j �
d�\| _ }}|� d�� d�| _
| j|td�| _zt| j � \| _| _W n* ty� tt�| j d�t����Y n0 | �� d S )N�://�/�;)�typez, )�superr �url�dict�app�confZcache_backend_options�optionsZ
cache_backend�backend� partition�rstrip�split�serversZprepare_expires�int�expires�backendsr r �KeyErrorr �UNKNOWN_BACKEND�format�joinZ_encode_prefixes) r r> rG rA r@ r< r �_rE �� __class__r r r b s$ � � zCacheBackend.__init__c C s | j �|�S r )�clientr! �r r# r r r r! w s zCacheBackend.getc C s | j �|�S r )rP r+ r) r r r �mgetz s zCacheBackend.mgetc C s | j �||| j�S r )rP r- rG �r r# r, r r r r- } s zCacheBackend.setc C s | j �|�S r )rP r. rQ r r r r. � s zCacheBackend.deletec s8 | � |d �}| jj|d| jd� t� j||fi |��S )Nr )�time)Zget_key_for_chordrP r- rG r; �_apply_chord_incr)r Zheader_result_args�bodyr Z chord_keyrN r r rU � s ��z CacheBackend._apply_chord_incrc C s | j �|�S r )rP r/ rQ r r r r/ � s zCacheBackend.incrc C s | j �||�S r )rP r2 rS r r r r1 � s zCacheBackend.expirec C s | j | jfi | j��S r )r rE r@ )r r r r rP � s zCacheBackend.clientr c sN |si n|}d� | j�}| j� d|� d�}|�|| j| jd�� t� �||�S )Nr9 r7 r8 )rA rG r@ )rL rE rA �updaterG r@ r; �
__reduce__)r r r rE rA rN r r rX � s ��zCacheBackend.__reduce__c O s d� | j�}| j� d|� d�S )zcReturn the backend as an URI.
This properly handles the case of multiple servers.
r9 r7 r8 )rL rE rA )r r r rE r r r �as_uri� s zCacheBackend.as_uri)NNNN)r N)r3 r4 r5 �__doc__rE Zsupports_autoexpireZsupports_native_joinZimplements_incrr r! rR r- r. rU r/ r1 r rP rX rY �
__classcell__r r rN r r Z s& �
r )rZ Zkombu.utils.encodingr r Zkombu.utils.objectsr Zcelery.exceptionsr Zcelery.utils.functionalr �baser �__all__r r rJ r r r r rH r r r r r �<module> s&
�