Файловый менеджер - Редактировать - /opt/imh-python/lib/python3.9/site-packages/celery/app/__pycache__/defaults.cpython-39.pyc
Ðазад
a t�h�; � > @ s� d Z ddlmZmZ ddlmZ ddlmZ ddlm Z dZ dZ dZ d � � Zd Zd Zd hZd hZdhZedd�Zd�dd�Zdd� ZG dd� d�Zeee ded�eddd�edd d�ed d ed�ed d ed�ed ed�eeedd d�ei d!d�ed"�ed#�edd$d�eded�d%�eedd d�edd d�edd d�ed d�ei d!d�ed&d d�edd d�edd d�ed'd$d�ed(d d�edd d�ed)d$d�ed*d$d�edd d�ed+d$d�ed(d d�ed d�ed$d�ed d�ed d�ed d�d,�eed-�e� ei d!d�d.�eed d�ed d�ed d�ed d�edd�ed d�ed d�ed d�ed d�ed d�ei d!d�d/� eed d�ed d�ed d�ed d�ed d�ed d�d0�eed1d d�ed2d$d�ed2d$d�ed3d$d�ed4d d�ed5d$d�ed)d$d�d6�eed d�ed d�ed4d d�edd d�d7�eed8d d�ed9d d�ed1d d�d:�eed;�edd!d�d<�eed=�edd!d�d<�eed>�ed!d�d<�eed?d d�ed@d d�edAd d�edBd$d�edCd$d�dD�eedE�edFd d�edGd d�edH�edI�edHd d�dJ�eedK�ed!d�ed$d�ed d�ed$d�ed d�ed d�ed$d�edLd d�edd d�ed(d d�ed(d d�dM� eedN�ed d�edOd$dPhd�edQd�edR�edS�eedTdU�d dVhd�edd d�ed(d d�edI�ei d!d�edWd d�ed*d d�edXd$d�eedY�d d�ed+d$d�ed(d d�dZ�eed[�ed d�ed$d�ed d�edd d�d\�eed]�ed d�ed d�ed d�ed^d�eed d�d_�eed`hda�ed!dbhd�ed(d dchd�ed!d�ed!ddhd�de�eeed(d d�edd d�ed(d d�edfd�ed dghd�edd d�ed(d d�ed2d d�ed1�edd d�edS�edd d�ed d�edd d�ed(d dhhd�ed(d d�ed(d d�ed2d$dihd�edd djhd�ed3ddTdkdl�d!dmhd�ed!d�edd$d�ed d�ed(d d�edfd�ed(d dnhd�edIdohda�ed dphd�ed dqhd�ed(d d�ed(d d�ed(d d�dr�!eeedd d�eds�ed(d d�edd$d�edtd d�ed(d duhd�ed(d dvhd�ed(d d�edd dwhd�edd d�ed d�ee�ed9d dxhd�ed$d�ed$d�ee �edd d�ed(d d�edyd d�ed&d$d�edd d�edd dzhd�ed{d|hda�ed(d d}hd�e� ee�ed d�edWd d�d~� d�Zd�d�� Zd�d�� Z d4efd�d��Z d�d�� e e�D �Z e e ee d���Z d�d�� e D �Z!d�d�� e D �Z"d�d�� e D �Z#dZ e$e �%� �Z&e$e#�%� �Z'd�d�� Z(edd��d�d�d���Z)dS )�z)Configuration introspection and defaults.� )�deque� namedtuple)� timedelta)�memoize)� strtobool)�Option� NAMESPACES�flatten�findZprefork)�jsonz> [%(asctime)s: %(levelname)s/%(processName)s] %(message)s zT[%(asctime)s: %(levelname)s/%(processName)s] %(task_name)s[%(task_id)s]: %(message)s�sha256z celery_{0}zcelerybeat_{0}z celeryd_{0}� searchresult)� namespace�key�typeNc s8 | d ur4|� � D ]"\� }|js� fdd�| D �|_q|S )Nc s h | ]}|� � ��qS � )�format)�.0�o�r r ��/root/rpmbuild/BUILDROOT/imh-python39-modules-3.9.7-92.el8.x86_64/opt/imh-python/lib/python3.9/site-packages/celery/app/defaults.py� <setcomp>" � z Namespace.<locals>.<setcomp>)�items�old)�__old__�options�optr r r � Namespace s r c C s | � d�hS )Nz_{0}r )�nsr r r �old_ns& s r c @ sT e Zd ZdZdZdZdZe� Ze e e dd� e e ed�Zd dd�Zdd � Zd d � ZdS ) r z(Describes a Celery configuration option.Nc C s | S �Nr )�vr r r �<lambda>1 r zOption.<lambda>)�string�int�float�any�bool�dict�tuplec O s8 || _ |�d�pd| _|�� D ]\}}t| ||� q d S )Nr r$ )�default�getr r �setattr)�selfr+ �args�kwargs�attr�valuer r r �__init__4 s zOption.__init__c C s | j | j |�S r! )�typemapr )r. r2 r r r � to_python: s zOption.to_pythonc C s d� | j| j�S )Nz <Option: type->{} default->{!r}>)r r r+ )r. r r r �__repr__= s �zOption.__repr__)N)�__name__� __module__� __qualname__�__doc__�alt� deprecate_by� remove_by�setr �strr% r& r r) r* r4 r3 r5 r6 r r r r r * s � r �list)r r )r Tr( r r* r$ r& r) z celery.beat:PersistentSchedulerzcelerybeat-scheduler% )r Zmax_loop_intervalZscheduleZ schedulerZschedule_filenameZ sync_everyZcron_starting_deadline� �d F�x g @� )�urlZread_urlZ write_url� transportZtransport_options�connection_timeoutZconnection_retryZconnection_retry_on_startupZconnection_max_retriesZchannel_error_retryZfailover_strategy� heartbeatZheartbeat_checkrateZ login_methodZ pool_limitZuse_ssl�host�port�user�passwordZvhostZ celery_cache)r �backendZbackend_options) Z entry_ttlZkeyspacerJ Zread_consistencyZserversZ bundle_path�tableZwrite_consistencyZ auth_providerZ auth_kwargsr )Z access_key_idZsecret_access_key�bucket� base_pathZ endpoint_url�region�celery� � � � )Zcontainer_nameZretry_initial_backoff_secZretry_increment_baseZretry_max_attemptsrP rG � read_timeout)rO �projectrP �ttlg �r@g $@)� queue_ttl� queue_expires�exchangeZcelery_couchbase)r Zbackend_settingsZcelery_arangodbZcelery_mongodbZcelerydbZ celerycol�Session� � )Z database_nameZcollection_nameZconsistency_levelZmax_retry_attemptsZmax_retry_wait_timeZ celery_eventg N@g @Zceleryevr )r r[ rZ Z queue_prefix� serializerr\ Z celery_redisg ^@) r Zbackend_use_ssl�dbrI Zmax_connections�usernamerL rJ �socket_timeoutZsocket_connect_timeout�retry_on_timeoutZsocket_keepaliveZ celery_result���Zcelery_max_cached_resultsr? Z celeryresults�direct� )�daysZcelery_task_result_expiresg �?i' �inf)r rM Z cache_max� compressionr\ Z exchange_type�expires� persistent�extendedr` Zbackend_transport_optionsZchord_retry_intervalZchord_join_timeoutZ$backend_max_sleep_between_retries_msZbackend_max_retriesZ%backend_base_sleep_between_retries_msZbackend_always_retryZcelery_elasticsearch)r rd � max_retries�timeoutZsave_meta_as_textZcelery_security�bytes)r Z certificateZ cert_storer � key_password�digestZcelery_result_dburi)r Z celery_result_engine_optionsZ%celery_result_db_short_lived_sessionsZcelery_result_db_tablenames)rE Zengine_optionsZshort_lived_sessionsZ table_schemasZ table_namesr' Zcelery_message_compressionZ"celery_eager_propagates_exceptionsZcelery_task_protocolZcelery_task_publish_retryg�������?)rn Zinterval_startZ interval_maxZ interval_stepZ celery_task_publish_retry_policyZcelery_send_task_sent_eventZcelery_task_serializerZ celeryd_task_soft_time_limitZceleryd_task_time_limit)!r Z acks_lateZacks_on_failure_or_timeoutZ always_eager� annotationsrj Zcreate_missing_queuesZinherit_parent_priorityZdefault_delivery_modeZ default_queueZdefault_exchangeZdefault_exchange_typeZdefault_routing_keyZdefault_rate_limitZdefault_priorityZeager_propagatesZ ignore_resultZstore_eager_result�protocolZ publish_retryZpublish_retry_policyZqueuesZqueue_max_priorityZreject_on_worker_lostZremote_tracebacksZroutesZsend_sent_eventr` Zsoft_time_limitZ time_limitZ store_errors_even_if_ignoredZ track_startedZ allow_error_cb_on_chord_headerz"celery.worker.autoscale:Autoscalerz celery.worker.consumer:ConsumerZcelery_worker_directZcelery_disable_rate_limitsZ celery_enable_remote_controlZceleryd_worker_lost_waitg @Zcelery_redirect_stdouts�WARNINGZ celery_redirect_stdouts_levelZcelery_send_events) r ZagentZ autoscalerZ,cancel_long_running_tasks_on_connection_lossZ concurrencyZconsumerrf Zdisable_rate_limitsZ deduplicate_successful_tasksZenable_remote_controlZhijack_root_loggerZ log_colorZ log_formatZ lost_waitZmax_memory_per_childZmax_tasks_per_child�poolZ pool_putlocksZ pool_restartsZproc_alive_timeoutZprefetch_multiplierZ enable_prefetch_count_reductionZredirect_stdoutsZredirect_stdouts_levelZsend_task_eventsZstate_dbZtask_log_formatZtimerZtimer_precision)Zaccept_contentZresult_accept_contentZ enable_utcZimports�include�timezoneZbeatZbroker�cacheZ cassandraZs3ZazureblockblobZgcs�controlZ couchbaseZarangodbZmongodbZ cosmosdbsql�eventZredis�resultZ elasticsearch�securityZdatabase�taskZworkerc C s | | |fgS r! r �r r r r r r � _flatten_keys` s r� c s6 �j r � ��fdd��j D �S �� �� �� �fgS )Nc s$ g | ] }|� � ��� �� �f�qS r )r �upper)r Zoldkey�r r r r r � <listcomp>f s �z _to_compat.<locals>.<listcomp>)r r� r r r� r � _to_compatd s �r� c c sj t || fg�}|rf|�� \}}|�� D ]<\}}t|t�rP|�|| d |f� q&||||�E dH q&qdS )zFlatten settings.�_N)r �popleftr � isinstancer) �append)�d�root� keyfilter�stackr r r r r r r r m s r c C s i | ]\}}||j �qS r �r+ )r r r r r r � <dictcomp>y s r� )r� c C s i | ]\}}}||j �qS r r� )r �old_keyr� r r r r r� } r c C s i | ]\}}}||�qS r r �r r� Znew_keyr� r r r r� ~ r c C s i | ]\}}}||�qS r r r� r r r r� r c C sb ddl m} tt�D ]H\}}|js(|jrt| |d �r|jd|�d�|j|jd|j� d�d� q| S )Nr )� deprecatedzThe z settingzUse the z instead)� description� deprecationZremoval� alternative) Z celery.utilsr� r r r< r= �getattr�warnr; )�sourcer� �namer r r r �find_deprecated_settings� s �r� )�maxsizec C s� |� � }z t|| � � t| | � � �W S ty� t�� D ]l\}}|� � | � � krhtd||� Y S t|t�r<z"t|| � � || � � �W Y S ty� Y q<0 q<Y n0 td| � � t| � � �S )zFind setting by name.N)�lowerr r �KeyErrorr r� r) �DEFAULTS)r� r r �optsr r r r � s � " r )N)rR )*r: � collectionsr r �datetimer Zcelery.utils.functionalr Zcelery.utils.serializationr �__all__Z DEFAULT_POOLZDEFAULT_ACCEPT_CONTENT�stripZDEFAULT_PROCESS_LOG_FMTZDEFAULT_TASK_LOG_FMTZDEFAULT_SECURITY_DIGESTZOLD_NSZ OLD_NS_BEATZ OLD_NS_WORKERr r r r r% r& r r� r� r r� r@ Z__compatZ _OLD_DEFAULTSZ _TO_OLD_KEYZ _TO_NEW_KEYr> �keysZ SETTING_KEYSZ_OLD_SETTING_KEYSr� r r r r r �<module> sn � � � � � � � � � �� � � ��� � � � �� � � ��� � �� �3 � ��� ��� �� � �
| ver. 1.1 | |
.
| PHP 8.3.30 | Ð“ÐµÐ½ÐµÑ€Ð°Ñ†Ð¸Ñ Ñтраницы: 0 |
proxy
|
phpinfo
|
ÐаÑтройка