
    `f:                     x   d Z ddlmZmZ ddlmZ ddlmZ ddlm	Z	 dZ
dZdZd	                                Zd
ZdZdhZdhZdhZ edd          ZddZd Z G d d          Z edi d eede          d edd          d edd          d edd e          d! edd e          d" ed#e          d$ ee edd%           ei d&           ed'           ed(           edd)           ede          *          d+ edi d, edd#          d- edd#          d. edd#          d/ ed#          d0 ei d&          d1 ed2d%          d3 edd          d4 edd          d5 ed6d)          d7 ed8d          d9 edd#          d: ed;d)          d< ed=d)          d> edd#          d? ed@d)          dA ed8d          dB ed#          dC ed)          dD ed#          dE ed#          dF ed#          dG e edH           e             ei d&          I          dJ e ed%           ed#           ed#           ed#           ed           ed#           ed#           ed#           ed#           ed#           ei d&          K          dL e ed#           ed#           ed#           ed#           ed#           ed#          M          dN e edOd#           edPd)           edPd)           edQd)           edRd#           edSd)           ed;d)          T          dU e edVd%           edWd%           edOd#          X          dY e edZ           edd&          [          d\ e ed]           edd&          [          d^ e ed_           ed&          [          d` e edad#           edbd#           edcd#           eddd)           eded)          f          dg e edh           edid%           edjd%           edk           edl           edkd#          m          dn e edo           ed&           ed)           ed#           ed)           ed#           ed#           ed)           edpd%           edd%           ed8d           ed8d          q          dr edi ds edt          du ed#          dv edwd)dxh          dy edz          d{ ed|          d} ed~          d e ed          d%dh          d edd          d ed8d          d edl          d ei d&          d edd%          d ed=d%          d edd)          d e ed          d%          d ed@d)          d ed8d          d e ed           ed           ed)           ed%           edd                    d e ed           ed#           ed#           ed#           ed           eed#                    d e edh           ed&dh           ed8ddh           ed&           ed&dh                    d edi dsed ed8d          d edd          d ed8d          d ed          dy ed#dh          d edd          d ed8d          d edPd#          d edO          d edd#          d ed~          d edd#          d ed#          d edd#          d ed8ddh          d ed8d          d ed8d          d edPd)dh          d edddh          d edQddddd&dh          d ed&          d edd)          d ed          d ed8d          d ed          d ed8ddh          d edldh          d ed%dh          d ed%dh          d ed8d          d ed8d          d ed8d          d edi dsed edd#          d ed̦          d ed8d          d edd)          d edd#          d~ ed8ddh          d ed8ddh          d ed8d          d edddh          d edd          d ed          d ee          d edWd%dh          d ed)          d ed)          d ee          d edd          d ed8d          d edd%          d ed2d)          d edddh          d eddh          d ed8ddh          d e            d ee          d ed#          d edd%          Zd Zd ZdRefdZd  ee          D             Z e eee                    Z d e D             Z!d e D             Z"d e D             Z#dZ  e$e%                                          Z& e$e#%                                          Z'd Z( ed          dd            Z)dS )z)Configuration introspection and defaults.    )deque
namedtuple)	timedelta)memoize)	strtobool)Option
NAMESPACESflattenfindprefork)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}zcelerybeat_{0}zceleryd_{0}searchresult)	namespacekeytypeNc                 t    | 4|                                 D ]\  }|j        sfd| D             |_         |S )Nc                 :    h | ]}|                               S  )format).0or   s     E/var/www/html/env/lib/python3.11/site-packages/celery/app/defaults.py	<setcomp>zNamespace.<locals>.<setcomp>"   s#    :::Q188C==:::    )itemsold)__old__optionsoptr   s      @r   	Namespacer!      sO     	; 	;HC7 ;::::':::Nr   c                     |  dhS )Nz_{0}r   )nss    r   old_nsr$   &   s    MMM?r   c                   \    e Zd ZdZdZdZdZ e            Ze	e
ed eeedZddZd Zd ZdS )	r   z(Describes a Celery configuration option.Nc                     | S Nr   )vs    r   <lambda>zOption.<lambda>1   s    1 r   )stringintfloatanybooldicttuplec                     || _         |                    d          pd| _        |                                D ]\  }}t	          | ||           d S )Nr   r*   )defaultgetr   r   setattr)selfr2   argskwargsattrvalues         r   __init__zOption.__init__4   s[    JJv&&2(	!<<>> 	' 	'KD%D$&&&&	' 	'r   c                 8     | j         | j                 |          S r'   )typemapr   )r5   r9   s     r   	to_pythonzOption.to_python:   s    &t|DI&u---r   c                 B    d                     | j        | j                  S )Nz <Option: type->{} default->{!r}>)r   r   r2   )r5   s    r   __repr__zOption.__repr__=   s&    1889=G G 	Gr   r'   )__name__
__module____qualname____doc__altdeprecate_by	remove_bysetr   strr+   r,   r   r/   r0   r<   r:   r=   r?   r   r   r   r   r   *   s        22
CLI
#%%CS5 $@ @G' ' ' '. . .G G G G Gr   r   accept_contentlist)r   r   result_accept_content)r   
enable_utcTr.   importsr   r0   includetimezoner*   beatr,   r/   zcelery.beat:PersistentSchedulerzcelerybeat-scheduler+   )r   max_loop_intervalschedule	schedulerschedule_filename
sync_everycron_starting_deadlinebrokerurlread_url	write_url	transporttransport_optionsconnection_timeout   connection_retryconnection_retry_on_startupconnection_max_retriesd   channel_error_retryFfailover_strategy	heartbeatx   heartbeat_checkrateg      @login_method
pool_limit
   use_sslhostportuserpasswordvhostcachecelery_cache)r   backendbackend_options	cassandra)	entry_ttlkeyspacerm   read_consistencyserversbundle_pathtablewrite_consistencyauth_providerauth_kwargsr   s3)access_key_idsecret_access_keybucket	base_pathendpoint_urlregionazureblockblobcelery          )container_nameretry_initial_backoff_secretry_increment_baseretry_max_attemptsr   r]   read_timeoutcontrolg     r@g      $@)	queue_ttlqueue_expiresexchange	couchbasecelery_couchbase)r   backend_settingsarangodbcelery_arangodbmongodbcelery_mongodbcosmosdbsqlcelerydb	celerycolSession	      )database_namecollection_nameconsistency_levelmax_retry_attemptsmax_retry_wait_timeeventcelery_eventg      N@g      @celeryevr   )r   r   r   queue_prefix
serializerr   rediscelery_redisg      ^@)r   backend_use_ssldbrl   max_connectionsusernamero   rm   socket_timeoutsocket_connect_timeoutretry_on_timeoutsocket_keepaliveresultr   celery_resultrs   	cache_maxcelery_max_cached_resultscompressionrH   r   celeryresultsexchange_typedirectexpires   )dayscelery_task_result_expires
persistentextendedr   backend_transport_optionschord_retry_intervalg      ?chord_join_timeout$backend_max_sleep_between_retries_msi'  backend_max_retriesinf%backend_base_sleep_between_retries_msbackend_always_retryelasticsearchcelery_elasticsearch)r   r   max_retriestimeoutsave_meta_as_textsecuritycelery_securitybytes)r   certificate
cert_storer   key_passworddigestdatabasecelery_result_dburi)r   celery_result_engine_options%celery_result_db_short_lived_sessionscelery_result_db_tablenames)rX   engine_optionsshort_lived_sessionstable_schemastable_namestask	acks_lateacks_on_failure_or_timeoutalways_eagerannotationsr-   celery_message_compressioncreate_missing_queuesinherit_parent_prioritydefault_delivery_modedefault_queuedefault_exchangedefault_exchange_typedefault_routing_keydefault_rate_limitdefault_priorityeager_propagates"celery_eager_propagates_exceptionsignore_resultstore_eager_resultprotocolcelery_task_protocolpublish_retrycelery_task_publish_retrypublish_retry_policyg?)r   interval_startinterval_maxinterval_step celery_task_publish_retry_policyqueuesqueue_max_priorityreject_on_worker_lostremote_tracebacksroutessend_sent_eventcelery_send_task_sent_eventcelery_task_serializersoft_time_limitceleryd_task_soft_time_limit
time_limitceleryd_task_time_limitstore_errors_even_if_ignoredtrack_startedallow_error_cb_on_chord_headerworkeragent
autoscalerz"celery.worker.autoscale:Autoscaler,cancel_long_running_tasks_on_connection_lossconcurrencyconsumerzcelery.worker.consumer:Consumercelery_worker_directdisable_rate_limitscelery_disable_rate_limitsdeduplicate_successful_tasksenable_remote_controlcelery_enable_remote_controlhijack_root_logger	log_color
log_format	lost_waitceleryd_worker_lost_waitmax_memory_per_childmax_tasks_per_childpoolpool_putlockspool_restartsproc_alive_timeoutg      @prefetch_multiplierredirect_stdoutscelery_redirect_stdoutsredirect_stdouts_levelWARNINGcelery_redirect_stdouts_levelsend_task_eventscelery_send_eventsstate_dbtask_log_formattimertimer_precisionc                     | |z   |fgS r'   r   r#   r   r    s      r   _flatten_keysr2  Y  s    #XsOr   c                 |     j         r fdj         D             S  z                                    z   fgS )Nc                 j    g | ]/}|                                                               z   f0S r   )r   upper)r   oldkeyr   r#   r    s     r   
<listcomp>z_to_compat.<locals>.<listcomp>_  sL     
 
 
 ]]3%%''c37
 
 
r   )r   r5  r1  s   ```r   
_to_compatr8  ]  sl    
w 

 
 
 
 
 
'
 
 
 	
 3hc3/00r   c              #   (  K   t          || fg          }|r{|                                \  }}|                                D ]K\  }}t          |t                    r|                    ||z   dz   |f           8 ||||          E d{V  L|ydS dS )zFlatten settings._N)r   popleftr   
isinstancer/   append)droot	keyfilterstackr#   r   r   r    s           r   r
   r
   f  s      D!9+E
 3mmooG 	3 	3HC#t$$ 3b3hnc23333$9Rc2222222222  3 3 3 3 3r   c                 $    i | ]\  }}||j         S r   r2   )r   r   r    s      r   
<dictcomp>rD  r  s-       !cC  r   )r@  c                 &    i | ]\  }}}||j         S r   rC  )r   old_keyr:  r    s       r   rD  rD  v  s"    FFF/'1c#+FFFr   c                     i | ]	\  }}}||
S r   r   r   rF  new_keyr:  s       r   rD  rD  w  !    DDD$7GWawDDDr   c                     i | ]	\  }}}||
S r   r   rH  s       r   rD  rD  x  rJ  r   c           	          ddl m} t          t                    D ]T\  }}|j        s|j        rAt          | |d           r0|                    d|d|j        |j        d|j         d           U| S )Nr   )
deprecatedzThe z settingzUse the z instead)descriptiondeprecationremovalalternative)	celery.utilsrM  r
   r	   rE   rF   getattrwarnrD   )sourcerM  namer    s       r   find_deprecated_settingsrW    s    ''''''Z(( F F	c 	F 	F7643N3N 	FOO(?t(?(?(?(+(8$'M(D37(D(D(D  F F F Mr   )maxsizec           	         |                                 }	 t          ||                                  t          |         |                                                     S # t          $ r t                                          D ]\  }}|                                 |                                  k    rt          d||          c cY S t          |t                    rP	 t          ||                                  ||                                                     c cY S # t          $ r Y w xY wY nw xY wt          d|                                  t          |                                                     S )zFind setting by name.N)lowerr   r	   KeyErrorr   r<  r/   DEFAULTS)rV  r   r#   optss       r   r   r     sb    !!Itzz||Z	%:4::<<%H
 
 	
  	 	 	"((** 	 	HBxxzzTZZ\\))#D"d3333333D$'' 'DJJLL$tzz||:LMMMMMMM   D	 		 djjllHTZZ\\,BCCCs=   AA A%D,D,:DD,
D%"D,$D%%D,+D,r'   )r   )*rC   collectionsr   r   datetimer   celery.utils.functionalr   celery.utils.serializationr   __all__DEFAULT_POOLDEFAULT_ACCEPT_CONTENTstripDEFAULT_PROCESS_LOG_FMTDEFAULT_TASK_LOG_FMTDEFAULT_SECURITY_DIGESTOLD_NSOLD_NS_BEATOLD_NS_WORKERr   r!   r$   r   r+   r,   r	   r2  r8  r
   r\  rJ   __compat_OLD_DEFAULTS_TO_OLD_KEY_TO_NEW_KEYrG   keysSETTING_KEYS_OLD_SETTING_KEYSrW  r   r   r   r   <module>rs     s   / / ) ) ) ) ) ) ) )       + + + + + + 0 0 0 0 0 0
5 " 	EGG +  #   z.*FGG     G G G G G G G G0 Y T T T60v6JJJJT &F3333T vd((((T F2G0000	T
 F2G0000T Vv....T 
 &111(((&:;; &!6776!%(((%vd555	
 	
 	
 	
T" 9   F4h''''8,,,, &H---- &h''''	
 !&&1111 "6!'2222  62222 %+F4f$=$=$=$=  &vc6666 #F5v6666 !&H5555 &5)))) #F3U3333 VDx0000 6"5))))  u6****!$ V""""%& V'( V"""")* X&&&&+, f(####- #TR )~&&r///	   ST^ i&g&&&X&&&V"""X...F###F)))f(### &h///f(+++F)))r'''   _Tx yf(+++ &h///v8$$$&h'''V***v8$$$   yTH 9vhX666"(&"7"7"7#VAE222!6!%000&(+++!6"5111VCe,,,   ITZ I&W---fT000x000   [Td i)**6222   eTn Y())6222   oTv I'((V,,,   wT@ 	fZh777{::: &:::!6!%000"F2E222   ATN )~&&fT000&7+++VJ''6&>>
222   OT` )~&&F+++6uV"""E***X&&&X&&&Vve'222%vd999F333F333   aT~ 9   ''' H%%%% &89
 
 
 
	 F&&&& ((( fX&&& I1;<
 
 
 
 6$V,,,,  F++++!" 6&>>>#$ #)&&"9"9"9"9%& $VCg6666'( "6#G4444)* .4VE-F-F-F-F+, #F55<<g>>>>-. /5fRe.D.D.D.D/0 $VE77771 Tr )-..V,,,F&&&G$$$ &F333   sTB Y())F)))6x(((F!!!V)))v-H===   CTT YF-.///v<=
 
 
 $V%L$M
 
 
 f&)))F-J,KLLL
 
 
 
UTj 
 2
 2
 2
2
&V,,,,2
 $*6$V#<#<#<#<2
 VE////	2

 F&&&&2
 F/K.LMMMM2
 %fT77772
 !'u6 : : : :2
 %fQX66662
 fX&&&2
  844442
 %fX...2
 #F4h77772
 "6x00002
  844442
   %I$J
 
 
 
!2
& fU0000'2
( "6%f5555)2
* ,B+CDDDD+2
, fv$?#@
 
 
 
-2
2 $V !# # @A
 
 
 
32
@ v6""""A2
B "6$U3333C2
D %f&1111E2
F !&V4444G2
H v5!!!!I2
J %B$C
 
 
 
K2
P 6&'?&@AAAAQ2
R =>
 
 
 
S2
X 689
 
 
 
Y2
^ &,VE%?%?%?%?_2
` fU0000a2
b (.ve&'A'A'A'Ac2
 2
kTP 9 + + ++fT))))+ 6>???+ 6<V6
 6
 6
 6
	+ F4e,,,,+ 9IIII+ ve&/E.FGGGG+ #F%A$B
 
 
 
+ &,V&
 &
 &
 &
+  %fv$B#C
 
 
 
!+& "6$V4444'+( &f%%%%)+* 61222++, &G2L1MNNNN-+. $V/////+0 #F....1+2 VL!!!3+4 fT////5+6 fU00007+8 "6#G44449+: #F151111;+<  v$=#>
 
 
 
=+B  &v;< 
  
  
  
C+H  %9$:
 
 
 
I+N O+P 3444Q+R f(####S+T s1111U+ +QT
n  1 1 1 - 	3 	3 	3 	3 %,WZ%8%8   4
j999::FFXFFFDD8DDDDD8DDDs8==??##C((**++    	D D D D D Dr   