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� � @ sz d Z ddlZddlZddlmZ ddlmZ ddlmZ ddlm Z ddl
m Z e� d�Z
d Zd
Zd ZG d d
� d
e �ZdS )z!File-system result store backend.� N)�datetime)� ensure_bytes)�uuid)�KeyValueStoreBackend)�ImproperlyConfiguredFz8You need to configure a path for the file-system backendzHA path for the file-system backend should conform to the file URI schemez�The configured path for the file-system backend does not
work correctly, please make sure that it exists and has
the correct permissions.c s~ e Zd ZdZdeejejef� fdd� Z d� fdd� Z
dd � Z d
d � Z d d
� Z
dd� Zdd� Zdd� Zdd� Zdd� Z� ZS )�FilesystemBackendas File-system result backend.
Arguments:
url (str): URL to the directory we should use
open (Callable): open function to use when opening files
unlink (Callable): unlink function to use when deleting files
sep (str): directory separator (to join the directory with the key)
encoding (str): encoding used on the file-system
Nc s� t � j|i |�� || _| �|�}tjdkrB|�d�rB|dd � }|�|�| _|�|�| _ || _
|| _ | � dt
� �|� � d S )N�nt�/� s .fs-backend-)�super�__init__�url�
_find_path�os�name�
startswith�encode�path�sep�open�unlink�_do_directory_testr ) �selfr
r r r �encoding�args�kwargsr �� __class__� �D/usr/local/lib/python3.9/site-packages/celery/backends/filesystem.pyr $ s
zFilesystemBackend.__init__r c s( |si n|}t � �|i |�d| ji��S )Nr
)r �
__reduce__r
)r r r r r r r 8 s z FilesystemBackend.__reduce__c C sD |s t t��|�d�r"|dd � S |�d�r8|dd � S t t��d S )Nzfile://localhost/� zfile://� )r �
E_NO_PATH_SETr � E_PATH_NON_CONFORMING_SCHEME)r r
r r r r < s
z FilesystemBackend._find_pathc C sL z,| � |d� | �|�dks J �| �|� W n tyF tt��Y n0 d S )Ns
test value)�set�get�delete�OSErrorr �E_PATH_INVALID�r �keyr r r r E s z$FilesystemBackend._do_directory_testc C s | j �| j|f�S �N)r �joinr r* r r r � _filenameM s zFilesystemBackend._filenamec C sX z@| � | �|�d��}|�� W d � W S 1 s40 Y W n tyR Y n0 d S )N�rb)r r. �read�FileNotFoundError)r r+ �infiler r r r& P s
, zFilesystemBackend.getc C sD | � | �|�d�� }|�t|�� W d � n1 s60 Y d S )N�wb)r r. �writer )r r+ �value�outfiler r r r% W s zFilesystemBackend.setc c s |D ]}| � |�V qd S r, )r& )r �keysr+ r r r �mget[ s zFilesystemBackend.mgetc C s | � | �|�� d S r, )r r. r* r r r r' _ s zFilesystemBackend.deletec C s� | j s
dS tddd| jjd�}| j�� | �� }|| j }t�| j�D ]R}| j | j
| j fD ]<}|� |�rZtj�
| j|�}t�|�j|k r�| �|� qFqZqFdS )zDelete expired meta-data.Ni� r
)�tzinfo)�expiresr Zapp�timezone�now�
total_secondsr �listdirr Ztask_keyprefixZgroup_keyprefixZchord_keyprefixr r- �stat�st_mtimer )r �epochZnow_tsZ cutoff_ts�filename�prefixr r r r �cleanupb s
�
zFilesystemBackend.cleanup)r N)�__name__�
__module__� __qualname__�__doc__r r r r �default_encodingr r r r r. r& r% r8 r' rD �
__classcell__r r r r r s
� r )rH �localer r Zkombu.utils.encodingr Zceleryr Zcelery.backends.baser Zcelery.exceptionsr �getpreferredencodingrI r# r$ r) r r r r r �<module> s
�