
     h_9                        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g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)          *          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d5d)          d6 edd#          d7 ed8d)          d9 ed:d)          d; edd#          d< ed=d)          d> ed?d          d@ ed#          dA ed)          dB ed#          dC ed#          dD ed#          dE e edF           e             ei d&          G          dH e ed%           ed#           ed#           ed#           ed           ed#           ed#           ed#           ed#           ei d&          I
  
        dJ e ed#           ed#           ed#           ed#           ed#           ed#          K          dL e edMd#           edNd)           edNd)           edOd)           edPd#           edQd)           ed8d)          R          dS e edTd%           edUd%           edMd#          V          dW e edX           edd&          Y          dZ e ed[           edd&          Y          d\ e ed]           ed&          Y          d^ e ed_d#           ed`d#           edad#           edbd)           edcd)          d          de e edf           edgd%           edhd%           edi           ed           edid#          j          dk e edl           ed&           ed)           ed#           ed)           ed#           ed#           ed)           edmd%           edd%           ed?d           ed?d          n          do edi dp edq          dr ed#          ds edtd)duh          dv edw          dx edy          dz ed{          d| e ed}~          d%dh          d edd          d ed?d          d ed          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d?d          d e ed           ed           ed)           ed%           edd                    d e ed           ed#           ed#           ed#           eed#                    d e edh           ed&dh           ed?ddh           ed&           ed&dh                    d edi dped ed?d          d edd          d ed?d          d ed          dv ed#dh          d edd          d ed?d          d edNd#          d edM          d edd#          d ed{          d edd#          d ed#          d edd#          d ed?ddh          d ed?d          d ed?d          d edNd)dh          d edddh          d edOdd}ddd&dh          d ed&          d edd)          d ed          d ed?d          d ed          d ed?ddh          d eddh          d ed%dh          d ed%dh          d ed?d          d ed?d          d edi dped edd#          d edǦ          d ed?d          d edd)          d edd#          d{ ed?ddh          d ed?ddh          d ed?d          d edddh          d edd          d ed          d ee          d edUd%dh          d ed)          d ed)          d ee          d edd          d ed?d          d edd%          d ed2d)          d edddh          d eddh          d ed?ddh          d e            d ee          d ed#          d edd%          Zd Zd ZdPe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     O/var/www/html/Sam_Eipo/venv/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brokerurlread_url	write_url	transporttransport_optionsconnection_timeout   connection_retryconnection_max_retriesd   failover_strategy	heartbeatx   heartbeat_checkrateg      @login_method
pool_limit
   use_sslFhostportuserpasswordvhostcachecelery_cache)r   backendbackend_options	cassandra)
	entry_ttlkeyspacerj   read_consistencyservers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      @celeryev)r   r   r   queue_prefix
serializerr   rediscelery_redisg      ^@)r   backend_use_ssldbri   max_connectionsusernamerl   rj   socket_timeoutsocket_connect_timeoutretry_on_timeoutsocket_keepaliveresultr   celery_resultrp   	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)r   certificate
cert_storer   digestdatabasecelery_result_dburi)r   celery_result_engine_options%celery_result_db_short_lived_sessionscelery_result_db_tablenames)rW   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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_keysr+  S  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>Y  sL     
 
 
 ]]3%%''c37
 
 
r   )r   r.  r*  s   ```r   
_to_compatr1  W  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
   `  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>r=  l  s-       !cC  r   )r9  c                 &    i | ]\  }}}||j         S r   r<  )r   old_keyr3  r    s       r   r=  r=  p  s"    FFF/'1c#+FFFr   c                     i | ]	\  }}}||
S r   r   r   r?  new_keyr3  s       r   r=  r=  q  !    DDD$7GWawDDDr   c                     i | ]	\  }}}||
S r   r   rA  s       r   r=  r=  r  rC  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.utilsrF  r
   r	   rE   rF   getattrwarnrD   )sourcerF  namer    s       r   find_deprecated_settingsrP  y  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   r5  r/   DEFAULTS)rO  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+  r1  r
   rU  rJ   __compat_OLD_DEFAULTS_TO_OLD_KEY_TO_NEW_KEYrG   keysSETTING_KEYS_OLD_SETTING_KEYSrP  r   r   r   r   <module>rl     s   / / ) ) ) ) ) ) ) )       + + + + + + 0 0 0 0 0 0
5   	EGG +  #   z.*FGG     G G G G G G G G0 Y N N N60v6JJJJN &F3333N vd((((N F2G0000	N
 F2G0000N Vv....N 
 &111(((&:;; &!6776!%(((
 
 
 
N  9   F4h''''8,,,, &H---- &h''''	
 !&&1111 "6!'2222  62222  &vc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(####) !NL )~&&r///	   MNX i&g&&&X&&&V"""X...F###f(### &h///f(+++F)))r'''   YNp yf(+++ &h///v8$$$&h'''V***v8$$$   qN@ 9vhX666"(&"7"7"7#VAE222!6!%000&(+++!6"5111VCe,,,   ANR I&W---fT000x000   SN\ i)**6222   ]Nf Y())6222   gNn I'((V,,,   oNx 	fZh777{::: &:::!6!%000"F2E222   yNF )~&&fT000&7+++VJ''6&>>
222   GNX )~&&F+++6uV"""E***X&&&X&&&Vve'222%vd999F333F333   YNv 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 wNj )-..V,,,F&&&G$$$ &F333   kNz Y())F)))6x(((F!!!v-H===   {NJ YF-.///v<=
 
 
 $V%L$M
 
 
 f&)))F-J,KLLL
 
 
 
KN` 
 1
 1
 1
1
&V,,,,1
 $*6$V#<#<#<#<1
 VE////	1

 F&&&&1
 F/K.LMMMM1
 %fT77771
 !'u6 : : : :1
 %fQX66661
 fX&&&1
  844441
 %fX...1
 #F4h77771
 "6x00001
  844441
   %I$J
 
 
 
!1
& fU0000'1
( "6%f5555)1
* ,B+CDDDD+1
, fv$?#@
 
 
 
-1
2 $V !# # @A
 
 
 
31
@ v6""""A1
B "6$U3333C1
D %f&1111E1
F !&V4444G1
H v5!!!!I1
J %B$C
 
 
 
K1
P 6&'?&@AAAAQ1
R =>
 
 
 
S1
X 689
 
 
 
Y1
^ &,VE%?%?%?%?_1
` fU0000a1
 1
aND 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+ +EN
b  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   