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
��Shw � @ st d Z ddlmZ ddlmZ ddlmZ ddlmZ z ddl Z W n e
yV dZ Y n0 dZ d Z G d
d � d e�Z
dS ) z CouchDB result store backend.� )� bytes_to_str)�
_parse_url)�ImproperlyConfigured� )�KeyValueStoreBackendN)� CouchBackendzKYou need to install the pycouchdb library to use the CouchDB result backendc sn e Zd ZdZdZdZdZdZdZdZ d� fdd� Z
d d
� Z e d d � �Z
d
d� Zdd� Zdd� Zdd� Z� ZS )r z�CouchDB backend.
Raises:
celery.exceptions.ImproperlyConfigured:
if module :pypi:`pycouchdb` is not available.
�default�http� localhosti` Nc s� t � j|i |�� || _td u r(tt��d } } } } }} |rlt|�\}
}}}}} }
| rh| �d�nd } |pt| j| _|p�| j | _ t
|p�| j �| _ | p�| j | _ |p�| j
| _
|p�| j| _d | _d S )N�/)�super�__init__�url� pycouchdbr �ERR_LIB_MISSINGr �strip�scheme�host�int�port� container�username�password� _connection) �selfr �args�kwargsZuschemeZuhostZuport�unameZupassZ
ucontainer�_�� __class__� �A/usr/local/lib/python3.9/site-packages/celery/backends/couchdb.pyr
$ s zCouchBackend.__init__c C s� | j rF| jrF| j� d| j � d| j� d| j� d| j� � }tj|dd�}n$| j� d| j� d| j� �}t�|�}z|�| j�W S tj j
y� |� | j� Y S 0 dS )z Connect to the CouchDB server.z://�:�@�basic)Z
authmethodN) r r r r r r �ServerZdatabaser �
exceptions�NotFound�create)r Z conn_string�serverr! r! r" �_get_connection9 s *
z CouchBackend._get_connectionc C s | j d u r| �� | _ | j S �N)r r+ �r r! r! r" �
connectionG s
zCouchBackend.connectionc C s8 t |�}z| j�|�d W S tjjy2 Y d S 0 d S )N�value)r r. �getr r' r( �r �keyr! r! r" r0 M s
zCouchBackend.getc C s^ t |�}||d�}z| j�|� W n6 tjjyX | j�|�}||d< | j�|� Y n0 d S )N)Z_idr/ r/ )r r. �saver r' �Conflictr0 )r r2 r/ �datar! r! r" �setT s
zCouchBackend.setc s � fdd�|D �S )Nc s g | ]}� � |��qS r! )r0 )�.0r2 r- r! r" �
<listcomp>` � z%CouchBackend.mget.<locals>.<listcomp>r! )r �keysr! r- r" �mget_ s zCouchBackend.mgetc C s | j �|� d S r, )r. �deleter1 r! r! r" r< b s zCouchBackend.delete)N)�__name__�
__module__� __qualname__�__doc__r r r r r r r
r+ �propertyr. r0 r6 r; r< �
__classcell__r! r! r r" r s
r )r@ Zkombu.utils.encodingr Zkombu.utils.urlr Zcelery.exceptionsr �baser r � ImportError�__all__r r r! r! r! r" �<module> s