File: //usr/local/lib/python3.9/site-packages/celery/app/__pycache__/utils.cpython-39.pyc
a
X>hs3 � @ 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}
zHAPI|TOKEN|KEY|SECRET|PASS|PROFANITIES_LIST|SIGNATURE|DATABASE|BEAT_DBURIzk
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 �:/usr/local/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