
    h=                        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dd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#A          dB edCd)          dD ed8d          dE ed#          dF ed)          dG ed#          dH ed#          dI ed#          dJ e edK           e             ei d&          L          dM e ed%           ed#           ed#           ed#           ed           ed#           ed#           ed#           ed#           ed#           ei d&          N          dO e ed#           ed#           ed#           ed#           ed#           ed#          P          dQ e edRd#           edSd)           edSd)           edTd)           edUd#           edVd)           ed;d)          W          dX e ed#           ed#           edUd#           edd%          Y          dZ e ed[d%           ed\d%           edRd#          ]          d^ e ed_           edd&          `          da e edb           edd&          `          dc e edd           ed&          `          de e edfd#           edgd#           edhd#           edid)           edjd)          k          dl e edm           ednd%           edod%           edp           edq           edpd#          r          ds e edt           ed&           ed)           ed#           ed)           ed#           ed#           ed)           edud%           edd%           ed8d           ed8d          v          dw edi dx edy          dz ed#          d{ ed|d)d}h          d~ ed          d ed          d ed          d e ed          d%dh          d edd          d ed8d          d edq          d ei d&          d edd%          d ed=d%          d edd)          d e ed          d%          d edCd)          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           edd                    d edi dxed ed8d          d edd          d ed8d          d ed          d~ ed#dh          d edd          d ed8d          d edSd#          d edR          d edd#          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dSd)dh          d edddh          d edTd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dqdh          d ed%dh          d ed%dh          d ed8d          d ed8d          d ed8d          d edi dxed edd#          d edӦ          d ed8d          d edd%          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d\d%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          d edddh          d eddh          d ed8ddh          d e            d ee          d ed#          d edd%          d edd          Zd Zd ZdUe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          dd            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     S/var/www/html/auto_sub_bot/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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"native_delayed_delivery_queue_typequorum)r2   r   
pool_limit
   use_sslhostportuserpasswordvhostcachecelery_cache)r   backendbackend_options	cassandra)	entry_ttlkeyspacero   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gcs)r   projectr   ttl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dbrn   max_connectionsusernamerq   ro   socket_timeoutsocket_connect_timeoutretry_on_timeoutsocket_keepaliveresultr   celery_resultru   	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create_tables_at_setup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_queue_typeclassic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soft_shutdown_timeoutg        enable_soft_shutdown_on_idle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enable_prefetch_count_reduction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_precisiondetect_quorum_queuesc                     | |z   |fgS r'   r   r#   r   r    s      r   _flatten_keysr>  f  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>l  sL     
 
 
 ]]3%%''c37
 
 
r   )r   rA  r=  s   ```r   
_to_compatrD  j  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  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>rP    s-       !cC  r   )rL  c                 &    i | ]\  }}}||j         S r   rO  )r   old_keyrF  r    s       r   rP  rP    s"    FFF/'1c#+FFFr   c                     i | ]	\  }}}||
S r   r   r   rR  new_keyrF  s       r   rP  rP    !    DDD$7GWawDDDr   c                     i | ]	\  }}}||
S r   r   rT  s       r   rP  rP    rV  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.utilsrY  r
   r	   rE   rF   getattrwarnrD   )sourcerY  namer    s       r   find_deprecated_settingsrc    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   rH  r/   DEFAULTS)rb  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	   r>  rD  r
   rh  rJ   __compat_OLD_DEFAULTS_TO_OLD_KEY_TO_NEW_KEYrG   keysSETTING_KEYS_OLD_SETTING_KEYSrc  r   r   r   r   <module>r     s   / / ) ) ) ) ) ) ) )       + + + + + + 0 0 0 0 0 0
5 " 	EGG +  #   z.*FGG     G G G G G G G G0 Y a a a60v6JJJJa &F3333a vd((((a F2G0000	a
 F2G0000a Vv....a 
 &111(((&:;; &!6776!%(((%vd555	
 	
 	
 	
a" 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 ,26(+R+R+R+R  6"5))))!" u6****#& V""""'( V)* V""""+, X&&&&-. f(####/ #aT )~&&r///	   Ua` i&g&&&X&&&V"""X...F###F)))f(### &h///f(+++F)))r'''   aaz yf(+++ &h///v8$$$&h'''V***v8$$$   {aJ 9vhX666"(&"7"7"7#VAE222!6!%000&(+++!6"5111VCe,,,   Ka\ 		v8$$$H%%%&(+++F17###		 	 	 	]ah I&W---fT000x000   iar i)**6222   sa| Y())6222   }aD I'((V,,,   EaN 	fZh777{::: &:::!6!%000"F2E222   Oa\ )~&&fT000&7+++VJ''6&>>
222   ]an )~&&F+++6uV"""E***X&&&X&&&Vve'222%vd999F333F333   oaL 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 Ma@ )-..V,,,F&&&G$$$ &F333   AaP Y())F)))6x(((F!!!V)))v-H===   Qab YF-.///v<=
 
 
 $V%L$M
 
 
 f&)))F-J,KLLL%vd888   caz 
 3
 3
 3
3
&V,,,,3
 $*6$V#<#<#<#<3
 VE////	3

 F&&&&3
 F/K.LMMMM3
 %fT77773
 !'u6 : : : :3
 %fQX66663
 fX&&&3
 "6)(;;;;3
  844443
 %fX...3
 #F4h77773
 "6x00003
   84444!3
"  %I$J
 
 
 
#3
( fU0000)3
* "6%f5555+3
, ,B+CDDDD-3
. fv$?#@
 
 
 
/3
4 $V !# # @A
 
 
 
53
B v6""""C3
D "6$U3333E3
F %f&1111G3
H !&V4444I3
J v5!!!!K3
L %B$C
 
 
 
M3
R 6&'?&@AAAAS3
T =>
 
 
 
U3
Z 689
 
 
 
[3
` &,VE%?%?%?%?a3
b fU0000c3
d (.ve&'A'A'A'Ae3
 3
{ab 9 / / //fT))))/ 6>???/ 6<V6
 6
 6
 6
	/ %fSw7777/ &,VE%?%?%?%?/ 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//0 &G2L1MNNNN1/2 $V////3/4 #F....5/6 VL!!!7/8 fT////9/: fU0000;/< "6#G4444=/> #F151111?/@ )/t&(A(A(A(AA/B  v$=#>
 
 
 
C/H  &v;< 
  
  
  
I/N  %9$:
 
 
 
O/T U/V 3444W/X f(####Y/Z s1111[/\ $VDv6666]/ /ca
H	  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   