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 ddlmZ ddlmZ ddlmZ ddlmZ ddl m
Z
z ddl Z W n e yb dZ Y n0 e
e
�ZdZd ZG d
d � d e�ZdS ) z�Consul result store backend.
- :class:`ConsulBackend` implements KeyValueStoreBackend to store results
in the key-value store of Consul.
� )� bytes_to_str)� parse_url)�KeyValueStoreBackend)�ImproperlyConfigured)�
get_loggerN)�
ConsulBackendz^You need to install the python-consul library in order to use the Consul result store backend.c sh e Zd ZdZeZdZdZdZ� fdd�Zdd� Z d d
� Z
d d � Z d
d� Z dd� Z
dd� Zdd� Z� ZS )r z'Consul.io K/V store backend for Celery.TZ
consistentNc sD t � j|i |�� | jd u r$tt��d | _| jf i t| j��� d S �N) �super�__init__�consulr �CONSUL_MISSING�
one_client�_init_from_paramsr �url)�self�args�kwargs�� __class__� �@/usr/local/lib/python3.9/site-packages/celery/backends/consul.pyr
% s
zConsulBackend.__init__c K s: t �d||� || _|| _|| _|�dd �r6| �� | _d S )Nz,Setting on Consul client to connect to %s:%dr
)�logger�debug�path�hostname�port�get�clientr
)r r r Z virtual_host�paramsr r r r 3 s � z ConsulBackend._init_from_paramsc C s | j ptj| j| j| jd�S )N)�hostr � consistency)r
r ZConsulr r r )r r r r r A s �zConsulBackend.clientc C s& t |�}| jd u r|S | j� d|� �S )N�/)r r �r �keyr r r �_key_to_consul_keyF s z ConsulBackend._key_to_consul_keyc C sL | � |�}t�d|� z | �� j�|�\}}|d W S tyF Y n0 d S )Nz"Trying to fetch key %s from Consul�Value)r$ r r r �kvr � TypeError)r r# �_�datar r r r J s
zConsulBackend.getc c s |D ]}| � |�V qd S r )r )r �keysr# r r r �mgetS s zConsulBackend.mgetc C sh t |�}| �|�}t�d|| j� | �� }|jj|d| jd�}t�d|� t�d|� |jj |||d�S )aM Set a key in Consul.
Before creating the key it will create a session inside Consul
where it creates a session with a TTL
The key created afterwards will reference to the session's ID.
If the session expires it will remove the key so that results
can auto expire from the K/V store
z.Trying to create Consul session %s with TTL %d�delete)�nameZbehaviorZttlzCreated Consul session %szWriting key %s to Consul)r# �value�acquire)
r r$ r r �expiresr �session�creater& �put)r r# r. Z session_namer Z
session_idr r r �setW s
�� zConsulBackend.setc C s& | � |�}t�d|� | �� j�|�S )NzRemoving key %s from Consul)r$ r r r r& r, r" r r r r, q s
zConsulBackend.delete)�__name__�
__module__� __qualname__�__doc__r Zsupports_autoexpirer r r
r r r$ r r+ r4 r, �
__classcell__r r r r r s r )r8 Zkombu.utils.encodingr Zkombu.utils.urlr Zcelery.backends.baser Zcelery.exceptionsr Zcelery.utils.logr r � ImportErrorr5 r �__all__r r r r r r �<module> s