Файловый менеджер - Редактировать - /opt/imh-python/lib/python3.9/site-packages/celery/app/__pycache__/utils.cpython-39.pyc
Ðазад
a t�hh3 � @ s� d Z ddlZddlZddlZddlmZ ddlmZ ddl m Z ddl m Z ddl mZ ddlmZ dd lmZ dd lmZ dd lmZmZmZ dd lmZ d dlm Z m Z m Z m Z m Z m!Z!m"Z" dZ#dZ$e�%dej&�Z'dZ(dZ)dZ*dd� Z+G dd� de�Z,e j-fdd�Z.e j-fdd �Z/ed d �Z0e0e e e/e(�Z1e0e e e.e)�Z2d-d d �Z3G d!d"� d"�Z4d#d$� Z5d%d&� Z6d'd(� Z7d)d*� Z8eefd+d,�Z9dS ).z?App utilities: Compat settings, bug-report tool, pickling apps.� N)� namedtuple)�Mapping)�deepcopy)� ModuleType)�maybe_sanitize_url)�ImproperlyConfigured)�pyimplementation)�ConfigurationView)�import_from_cwd�qualname�symbol_by_name��pretty� )� _OLD_DEFAULTS�_OLD_SETTING_KEYS� _TO_NEW_KEY� _TO_OLD_KEY�DEFAULTS� SETTING_KEYS�find)�Settings�appstr� bugreport�filter_hidden_settings�find_appa software -> celery:{celery_v} kombu:{kombu_v} py:{py_v} billiard:{billiard_v} {driver_v} platform -> system:{system} arch:{arch} kernel version:{kernel_version} imp:{py_i} loader -> {loader} settings -> transport:{transport} results:{results} {human_settings} z=API|TOKEN|KEY|SECRET|PASS|PROFANITIES_LIST|SIGNATURE|DATABASEzk Cannot mix new and old setting keys, please rename the following settings to the new format: {renames} z� Cannot mix new setting names with old setting names, please rename the following settings to use the old format: {renames} Or change all of the settings to use the new format :) z{replace:<36} -> {with_}c C s | j pd� dt| �d��S )z1String used in __repr__ etc, to id app instances.�__main__z at z#x)�main�id)�app� r ��/root/rpmbuild/BUILDROOT/imh-python39-modules-3.9.7-92.el8.x86_64/opt/imh-python/lib/python3.9/site-packages/celery/app/utils.pyr A s r c s� e Zd ZdZdd�� fdd� Zedd� �Zedd � �Zed d � �Zed d � �Z edd� �Z edd� �Z edd� �Z dd� Z dd� Zd*dd�Zd+d d �Zd d � Zd d!� Zd,d$d%�Zd-d&d'�Zd(d)� Z� ZS ).r zsCelery settings object. .. seealso: :ref:`configuration` for a full list of configuration keys. N)�deprecated_settingsc s t � j|i |�� || _d S �N)�super�__init__r" )�selfr" �args�kwargs�� __class__r r! r% O s zSettings.__init__c C s t j�d�p| �d�p| jS )NZCELERY_BROKER_READ_URL�broker_read_url��os�environ�get� broker_url�r& r r r! r+ T s ��zSettings.broker_read_urlc C s t j�d�p| �d�p| jS )NZCELERY_BROKER_WRITE_URL�broker_write_urlr, r1 r r r! r2 \ s ��zSettings.broker_write_urlc C s t j�d�p| �dd�S )NZCELERY_BROKER_URLr0 Z broker_host�r- r. r/ �firstr1 r r r! r0 d s �zSettings.broker_urlc C s t j�d�p| �dd�S )NZCELERY_RESULT_BACKEND�result_backendr3 r1 r r r! r5 k s �zSettings.result_backendc C s | � dd�S )N�task_default_exchange�task_default_queue�r4 r1 r r r! r6 r s �z Settings.task_default_exchangec C s | � dd�S )N�task_default_routing_keyr7 r8 r1 r r r! r9 y s �z!Settings.task_default_routing_keyc C s | � dd�S )N�timezoneZ TIME_ZONEr8 r1 r r r! r: � s zSettings.timezonec C s t i | jdd� �S )z7Return the current configuration, but without defaults.N���)r �mapsr1 r r r! �without_defaults� s zSettings.without_defaultsc C s || � � v S r# )r= )r& �keyr r r! � value_set_for� s zSettings.value_set_for� c C s t ||�S )a� Search for option by name. Example: >>> from proj.celery import app >>> app.conf.find_option('disable_rate_limits') ('worker', 'prefetch_multiplier', <Option: type->bool default->False>)) Arguments: name (str): Name of option, cannot be partial. namespace (str): Preferred name-space (``None`` by default). Returns: Tuple: of ``(namespace, key, type)``. )r �r& �name� namespacer r r! � find_option� s zSettings.find_option�celeryc C s | j | �||�dd� � S )z6Shortcut to ``get_by_parts(*find_option(name)[:-1])``.Nr; )� get_by_partsrD rA r r r! �find_value_for_key� s zSettings.find_value_for_keyc G s | d� dd� |D �� S )z�Return the current value for setting specified as a path. Example: >>> from proj.celery import app >>> app.conf.get_by_parts('worker', 'disable_rate_limits') False �_c s s | ]}|r|V qd S r# r )�.0�partr r r! � <genexpr>� � z(Settings.get_by_parts.<locals>.<genexpr>)�join)r& �partsr r r! rF � s zSettings.get_by_partsc C s$ z | d W n t y Y n0 | S )NZ __bogus__)�KeyErrorr1 r r r! �finalize� s zSettings.finalizeFTc sJ |rt ndd� }tt�� | �� |r(| n| �� }|� fdd�|�� D ��S )Nc S s | S r# r )�vr r r! �<lambda>� rL z Settings.table.<locals>.<lambda>c s( i | ] \}}|� d �s|� vr||�qS )rH )� startswith�rI �krQ �Z dict_membersr r! � <dictcomp>� s �z"Settings.table.<locals>.<dictcomp>)r �dir�dictrP r= �items)r& � with_defaults�censoredZfilt�settingsr rV r! �table� s �zSettings.tablec C s d� dd� | �||��� D ��S )z;Return a human readable text showing configuration changes.� c s s( | ] \}}|� d t |dd�� �V qdS )z: �2 )�widthNr )rI r> �valuer r r! rK � s �z$Settings.humanize.<locals>.<genexpr>)rM r^ rZ )r& r[ r\ r r r! �humanize� s �zSettings.humanizec C sV | j rRddlm} ddlm} | j D ](}|jd|�d�dd|| � d�d � q$d S d S ) Nr )r )� deprecatedzThe z settingz6.0.0zUse the z instead)� descriptionZremoval� alternativeTF)r" Zcelery.app.defaultsr Z celery.utilsrd �warn)r& r rd Zsettingr r r! � maybe_warn_deprecated_settings� s �z'Settings.maybe_warn_deprecated_settings)r@ )rE )FT)FT)�__name__� __module__� __qualname__�__doc__r% �propertyr+ r2 r0 r5 r6 r9 r: r= r? rD rG rF rP r^ rc rh � __classcell__r r r) r! r F s2 r c C s || | �S r# r �r> �convertr r r! �_new_key_to_old� s rq c C s || | �S r# r ro r r r! �_old_key_to_new� s rr Zsettings_info_t)�defaultsrp Zkey_t� mix_errorc sr |si n|}|st � n|}|s"tn|}|s.tn|}| }| d u rH|i }} t |�� �| � � �|�}� �|�}d �|r�t| �} |r�t|�t|�kr�t| �} |rΈs�t| �} |r�t|�t|�kr�t| �} n t| �} |r�tt � �} � �fdd�| D �} | �r,t�j j d� �fdd�t | �D ��d����fdd�|� � D �}tt�j�fi |��} t|| | gttf||d �S ) Nc s h | ]}�j | � vr|�qS r )rp �rI r> �Zhave�infor r! � <setcomp> rL z"detect_settings.<locals>.<setcomp>r_ c 3 s" | ]}t j|� j| d �V qdS ))�replaceZwith_N)�FMT_REPLACE_SETTING�formatrp ru �rw r r! rK s �z"detect_settings.<locals>.<genexpr>)�renamesc s i | ]\}}� j �||�|�qS r )rp r/ rT r| r r! rW rL z#detect_settings.<locals>.<dictcomp>)r" �prefix)�setr r �keys� intersection�_settings_info�len�_old_settings_infor rt r{ rM �sortedrZ rY r rs r rr rq ) �confZpreconfZ ignore_keysr~ �all_keysZold_keys�sourceZ is_in_newZ is_in_old�leftZ really_leftrs r rv r! �detect_settings� sH ��r� c @ s: e Zd ZdZdd� Zdd� Zdd� Zd d d �Zd d � ZdS )� AppPicklerz*Old application pickler/unpickler (< 3.1).c G s2 | j |� }| j|fi |��}| j|fi |�� |S r# )� build_kwargs� construct�prepare)r& �clsr' r( r r r r! �__call__$ s zAppPickler.__call__c K s |j �|d � d S )N�changes)r� �update)r& r r( r r r! r� * s zAppPickler.preparec G s | j |� S r# )�build_standard_kwargs)r& r' r r r! r� - s zAppPickler.build_kwargsNc C s ||||||||d| d� S )NF) r �loader�backend�amqpr� �events�log�control�set_as_current� config_sourcer ) r& r r� r� r� r� r� r� r� Zaccept_magic_kwargsr� r r r! r� 0 s �z AppPickler.build_standard_kwargsc K s |f i |��S r# r )r& r� r( r r r! r� 8 s zAppPickler.construct)N) ri rj rk rl r� r� r� r� r� r r r r! r� ! s � r� c G s |� | g|�R � S )z Rebuild app for versions 2.5+.r )r� Zpicklerr' r r r! � _unpickle_app< s r� c C s d|d< | f i |��S )z Rebuild app for versions 3.1+.Fr� r )r� r( r r r! �_unpickle_app_v2A s r� c s ddd�� � fdd�| � � D �S )zFilter sensitive settings.�********c S sn t |t�rt|�S t | t�rjt�| �r*|S d| �� v rRddlm} ||�j |d�S d| �� v rjt ||d�S |S )Nr0 r )� Connection)�maskr� ) � isinstancer r �str�HIDDEN_SETTINGS�search�lower�kombur� �as_urir )r> rb r� r� r r r! � maybe_censorI s z,filter_hidden_settings.<locals>.maybe_censorc s i | ]\}}|� ||��qS r r rT �r� r r! rW W rL z*filter_hidden_settings.<locals>.<dictcomp>)r� )rZ )r� r r� r! r G s r c C s� ddl }ddl}ddl}z(| �� }d�|jj|j�� �}|j}W n t yZ d }}Y n0 t jt � � d� dd� t �� D ��t �� t� |j|j|jt �� ||t| jjp�d�| j�� t| jj�d � S ) z=Return a string containing information useful in bug-reports.r Nz{}:{}r@ z, c s s | ]}|r|V qd S r# r )rI �xr r r! rK k rL z bugreport.<locals>.<genexpr>�disabled) �system�archZkernel_versionZpy_iZcelery_vZkombu_vZ billiard_vZpy_v�driver_v� transport�resultsZhuman_settingsr� )�billiardr� rE � connectionr{ r� Z driver_nameZdriver_versionZ transport_cls� Exception�BUGREPORT_INFO� _platformr� rM � architecture�releaser ZVERSION_BANNER� __version__�python_versionr r� r5 rc r r� r* )r r� r� rE �connr� r� r r r! r Z s4 � �r c C s, ddl m} z|| |d�}W n ty6 || �}Y n0 t|t��r(d| v�r(z|j}t|t�rft� �W n� t�y" z |j}t|t�r�td��W n� t�y t|dd�r�z t| � d�||d �W Y Y S t y� Y n0 t |�� � D ] }t||�r�| Y Y S q� Y n 0 | Y S Y n0 |S |S ) zFind app by name.r )�Celery)�imp�:zBattribute 'celery' is the celery module not the instance of celery�__path__Nz.celery)r r� ) �baser� �AttributeErrorr� r r rE �getattrr � ImportError�vars�values)r r r� r� �sym�foundZsuspectr r r! r z sB � � r )NNNNN):rl r- �platformr� �re� collectionsr �collections.abcr �copyr �typesr Zkombu.utils.urlr Zcelery.exceptionsr Zcelery.platformsr Zcelery.utils.collectionsr Zcelery.utils.importsr r r Zcelery.utils.textr rs r r r r r r r �__all__r� �compile� IGNORECASEr� ZE_MIX_OLD_INTO_NEWZE_MIX_NEW_INTO_OLDrz r r r/ rq rr Z_settings_info_tr� r� r� r� r� r� r r r r r r r! �<module> sX $ � �� � 9
| ver. 1.1 | |
.
| PHP 8.3.30 | Ð“ÐµÐ½ÐµÑ€Ð°Ñ†Ð¸Ñ Ñтраницы: 0 |
proxy
|
phpinfo
|
ÐаÑтройка