Файловый менеджер - Редактировать - /opt/imh-python/lib/python3.9/site-packages/celery/fixups/__pycache__/django.cpython-39.pyc
Ðазад
a t�h� � @ s@ d Z ddlZddlZddlZddlmZmZ ddlmZ ddlm Z m Z m Z m Z m Z mZ ddlmZ ddlmZ ddlmZmZ dd lmZmZ e r�dd lmZ dd lmZ dd l m Z dd l m Z ddl m!Z! G dd� de�Z"dZ#dZ$e dd�dd�Z%ddd�dd�Z&d#de'e d d �d d �Z(G d d � d �Z)G d!d"� d"�Z*dS )$z Django-specific customization.� N)�datetime�timezone)� import_module)�IO� TYPE_CHECKING�Any�List�Optional�cast��symbol_by_name)�cached_property)�_state�signals)� FixupWarning�ImproperlyConfigured)� ModuleType)�Protocol)�ConnectionHandler)�Celery)�Taskc @ s e Zd ZU eed< dS )�DjangoDBModule� connectionsN)�__name__� __module__� __qualname__r �__annotations__� r r ��/root/rpmbuild/BUILDROOT/imh-python39-modules-3.9.7-92.el8.x86_64/opt/imh-python/lib/python3.9/site-packages/celery/fixups/django.pyr s r )� DjangoFixup�fixupzpEnvironment variable DJANGO_SETTINGS_MODULE is defined but Django isn't installed. Won't apply Django fix-ups! )�fh�returnc C s0 zt �| �� � W n tttfy* Y n0 d S �N)�os�close�fileno�AttributeError�OSError� TypeError)r! r r r �_maybe_close_fd$ s r* r )�djangor" c C s | j dk rtd��d S )N)� � z)Celery 5.x requires Django 1.11 or later.)�VERSIONr )r+ r r r �_verify_django_version, s r/ �DJANGO_SETTINGS_MODULEr r )�app�envr" c C sd t j�|�}|r`d| j�� vr`z ddl}W n tyJ t�t t �� Y n0 t |� t | �� � S dS )z;Install Django fixup if settings module environment is set.r+ r N)r$ �environ�get� loader_cls�lowerr+ � ImportError�warnings�warnr �ERR_NOT_INSTALLEDr/ r �install)r1 r2 ZSETTINGS_MODULEr+ r r r r 1 s r c @ s� e Zd ZdZdd�dd�Zd d�dd�Zed d�d d ��Zejd d d �dd ��Ze d d�dd�Z e d d�dd�Z d e e d�dd�Zee d�dd�Zee d�dd��Zd S ) r z"Fixup installed when using Django.r )r1 c C s$ || _ tjd u r| j �� d | _d S r# )r1 r Z default_app� set_default� _worker_fixup��selfr1 r r r �__init__B s zDjangoFixup.__init__�r" c C sX t j�dt�� � td�| _| j| jj _| jj s8d| j_ t j �| j� t j�| j� | S )Nr �django.conf:settingsz%celery.contrib.django.task:DjangoTask)�sys�path�insertr$ �getcwdr � _settings�nowr1 �loaderZ_custom_task_cls_usedZtask_clsr Zimport_modules�connect�on_import_modulesZ worker_init�on_worker_init�r? r r r r; H s zDjangoFixup.install�DjangoWorkerFixupc C s | j d u rt| j�| _ | j S r# )r= rN r1 rM r r r � worker_fixupX s zDjangoFixup.worker_fixupN)�valuer" c C s || _ d S r# )r= )r? rP r r r rO ^ s ��kwargsr" c K s | j �� d S r# )rO �validate_models�r? rR r r r rK b s z DjangoFixup.on_import_modulesc K s | j �� d S r# )rO r; rT r r r rL f s zDjangoFixup.on_worker_initF)�utcr" c C s |rt �tj�S | �� S r# )r rH r rU �_now)r? rU r r r rH i s zDjangoFixup.nowc C s ddl m} dd� |�� D �S )Nr )�appsc S s g | ] }|j �qS r )�name)�.0�configr r r � <listcomp>n � z2DjangoFixup.autodiscover_tasks.<locals>.<listcomp>)Z django.appsrW Zget_app_configs)r? rW r r r �autodiscover_tasksl s z DjangoFixup.autodiscover_tasksc C s t d�S )Nzdjango.utils.timezone:nowr rM r r r rV p s zDjangoFixup._now)F)r r r �__doc__r@ r; �propertyrO �setterr rK rL �boolr rH r �strr] r rV r r r r r ? s c @ s� e Zd ZdZddd�dd�Zdd�dd �Zdd�d d �Zd d�d d �Zedd�dd�Z e dd�dd�Z dedd�dd�Z dedd�dd�Z edd�dd�Zd"edd �d d �Zdd�d d!�ZdS )#rN r r N)r1 r" c C sV || _ | j j�dd �| _tdtd��| _td�| _td�| _ td�f| _ td�| _ d S )NZCELERY_DB_REUSE_MAXr z django.dbzdjango.core.cacherB z django.db.utils.InterfaceErrorzdjango.db:DatabaseError) r1 Zconfr4 � db_reuse_maxr r �_db�_cacher rG �interface_errors� DatabaseErrorr> r r r r@ x s �zDjangoWorkerFixup.__init__rA c C s dd l }|�� d S )Nr )r+ �setup)r? r+ r r r � django_setup� s z DjangoWorkerFixup.django_setupc C s* ddl m} | �� tj�d�s&|� d S )Nr )� run_checksZCELERY_SKIP_CHECKS)Zdjango.core.checksrj ri r$ r3 r4 )r? rj r r r rS � s z!DjangoWorkerFixup.validate_modelsc C sL t j�| j� t j�| j� t j�| j� t j�| j � | �� | � � | S r# ) r Zbeat_embedded_initrJ �close_databaseZ task_prerun�on_task_prerunZ task_postrun�on_task_postrunZworker_process_init�on_worker_process_init� close_cacherM r r r r; � s zDjangoWorkerFixup.installrQ c K sT t j�d�r| �� | jj�� D ]}|r |jr | �|j� q | j dd� | � � d S )NZFORKED_BY_MULTIPROCESSINGT)�force) r$ r3 r4 rS rd r �all� connection�_maybe_close_db_fd�_close_databasero )r? rR �cr r r rn � s z(DjangoWorkerFixup.on_worker_process_init)�fdr" c C s& z t |� W n | jy Y n0 d S r# )r* rf )r? rv r r r rs � s z$DjangoWorkerFixup._maybe_close_db_fdr )�senderrR r" c K s t |jdd�s| �� dS )zCalled before every task.�is_eagerFN)�getattr�requestrk �r? rw rR r r r rl � s z DjangoWorkerFixup.on_task_prerunc K s" t |jdd�s | �� | �� d S )Nrx F)ry rz rk ro r{ r r r rm � s z!DjangoWorkerFixup.on_task_postrunc K s> | j s| �� S | j| j d kr,d| _| �� | jd7 _d S )N� r r, )rc rt � _db_recyclesrT r r r rk � s z DjangoWorkerFixup.close_databaseF)rp r" c C s� | j j�� D ]r}z|r |�� n|�� W q | jy> Y q | jy| } z&t|�}d|vrhd|vrh� W Y d }~q d }~0 0 q d S )N�closedz not connected)rd r rq r% Z close_if_unusable_or_obsoleterf rg rb )r? rp �conn�excZstr_excr r r rt � s z!DjangoWorkerFixup._close_databasec C s* z| j �� W n ttfy$ Y n0 d S r# )re Z close_cachesr) r' rM r r r ro � s z DjangoWorkerFixup.close_cache)F)r r r r} r@ ri rS r; r rn r rs rl rm rk ra rt ro r r r r rN u s rN )r0 )+r^ r$ rC r8 r r � importlibr �typingr r r r r r Zkombu.utils.importsr Zkombu.utils.objectsr Zceleryr r Zcelery.exceptionsr r �typesr r Zdjango.db.utilsr Zcelery.app.baser Zcelery.app.taskr r �__all__r: r* r/ rb r r rN r r r r �<module> s0 6
| ver. 1.1 | |
.
| PHP 8.3.30 | Ð“ÐµÐ½ÐµÑ€Ð°Ñ†Ð¸Ñ Ñтраницы: 0 |
proxy
|
phpinfo
|
ÐаÑтройка