File: //usr/local/lib/python3.9/site-packages/celery/app/__pycache__/defaults.cpython-39.pyc
a
X>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 d�ed d�ed$d�ed d�ed d�ed d�d.�eed/�e� ei d!d�d0�eed d�ed d�ed d�ed d�edd�ed d�ed d�ed d�ed d�ed d�ei d!d�d1� eed d�ed d�ed d�ed d�ed d�ed d�d2�eed3d d�ed4d$d�ed4d$d�ed5d$d�ed6d d�ed7d$d�ed)d$d�d8�eed d�ed d�ed6d d�edd d�d9�eed:d d�ed;d d�ed3d d�d<�eed=�edd!d�d>�eed?�edd!d�d>�eed@�ed!d�d>�eedAd d�edBd d�edCd d�edDd$d�edEd$d�dF�eedG�edHd d�edId d�edJ�edK�edJd d�dL�eedM�ed!d�ed$d�ed d�ed$d�ed d�ed d�ed$d�edNd d�edd d�ed(d d�ed(d d�dO� eedP�ed d�edQd$dRhd�edSd�edT�edU�eedVdW�d dXhd�edd d�ed(d d�edK�ei d!d�edYd d�ed*d d�edZd$d�eed[�d d�ed-d$d�ed(d d�d\�eed]�ed d�ed$d�ed d�edd d�d^�eed_�ed d�ed d�ed d�ed`d�eed d�da�eedbhdc�ed!ddhd�ed(d dehd�ed!d�ed!dfhd�edd d�dg�eeed(d d�edd d�ed(d d�edhd�ed dihd�edd d�ed(d d�ed4d d�ed3�edjd d�edd d�edU�edd d�ed d�edd d�ed(d dkhd�ed(d d�ed(d d�ed4d$dlhd�edd dmhd�ed5ddVdndo�d!dphd�ed!d�edd$d�ed d�ed(d d�edhd�ed(d dqhd�edKdrhdc�ed dshd�ed dthd�ed(d d�ed(d d�ed(d d�du�"eeedd d�edv�ed(d d�edwd d�ed(d d�edd$d�edxd d�ed(d dyhd�ed(d dzhd�ed(d d�edd d{hd�edd d�ed d�ee�ed;d d|hd�ed$d�ed$d�ee �edd d�ed(d d�ed}d d�ed&d$d�edd d�edd d~hd�edd�hdc�ed(d d�hd�e� ee�ed d�edYd d�edd d�d�� d��Zd�d�� Zd�d�� Z d6efd�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 �=/usr/local/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 @Zquorum)r+ r �
)�urlZread_urlZ write_url� transportZtransport_options�connection_timeoutZconnection_retryZconnection_retry_on_startupZconnection_max_retriesZchannel_error_retryZfailover_strategyZ heartbeatZheartbeat_checkrateZ login_methodZ"native_delayed_delivery_queue_typeZ
pool_limitZuse_ssl�host�port�user�passwordZvhostZ celery_cache)r �backendZbackend_options) Z entry_ttlZkeyspacerI Zread_consistencyZserversZ bundle_path�tableZwrite_consistencyZ
auth_providerZ auth_kwargsr )Z
access_key_idZsecret_access_key�bucket� base_pathZ endpoint_urlZregion�celery� � � � )Zcontainer_nameZretry_initial_backoff_secZretry_increment_baseZretry_max_attemptsrO rG � read_timeout)rN �projectrO Zttlg �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 rX rW Z queue_prefix�
serializerrY Z celery_redisg ^@) r Zbackend_use_ssl�dbrH Zmax_connections�usernamerK rI �socket_timeoutZsocket_connect_timeout�retry_on_timeoutZsocket_keepaliveZ
celery_result���Zcelery_max_cached_resultsr? Z
celeryresults�direct� )�daysZcelery_task_result_expiresg �?i' �inf)r rL Z cache_max� compressionrY 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 ra � 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_namesZcreate_tables_at_setupr' Zcelery_message_compressionZclassicZ"celery_eager_propagates_exceptionsZcelery_task_protocolZcelery_task_publish_retryg�������?)rk 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� annotationsrg Zcreate_missing_queuesZinherit_parent_priorityZdefault_delivery_modeZ
default_queueZdefault_queue_typeZdefault_exchangeZdefault_exchange_typeZdefault_routing_keyZdefault_rate_limitZdefault_priorityZeager_propagatesZ
ignore_resultZstore_eager_result�protocolZ
publish_retryZpublish_retry_policy�queuesZqueue_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:Autoscalerg z 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_lossZsoft_shutdown_timeoutZ enable_soft_shutdown_on_idleZ concurrencyZconsumerrc 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_format�timerZtimer_precisionZdetect_quorum_queues)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_keysf 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>l s �z _to_compat.<locals>.<listcomp>)r r� r~ r r� r �
_to_compatj 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 s s
r c C s i | ]\}}||j �qS r �r+ )r r r r r r �
<dictcomp> 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)rP )*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> sz
�
�
�
�
�
�
�
�
�
��
�
�
���
�
�
�
��
�
�
���
� ��
�4
�
���
���
�� � & �