
    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	j                         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 ee      D  ci c]  \  } }| |j<                   c}} Z e  eee            Z!e!D ci c]  \  }}}||j<                   c}}}Z"e!D ci c]	  \  }}}|| c}}}Z#e!D ci c]	  \  }}}|| c}}}Z$dZ! e%ejM                               Z' e%e$jM                               Z(d Z) ed       dd       Z*yc c}} w c c}}}w c c}}}w c c}}}w (  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                     | I|j                         D ]6  \  }}|j                  r| D ch c]  }|j                  |       c}|_        8 |S c c}w N)itemsoldformat)__old__optionsr   optos        O/var/www/Befach/backend/env/lib/python3.12/site-packages/celery/app/defaults.py	Namespacer      sI    HC7729:Q188C=: ( N ;s   Ac                     |  dhS )Nz_{0} )nss    r   old_nsr!   &   s    d&M?    c                   T    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y)	r   z(Describes a Celery configuration option.Nc                     | S r   r   )vs    r   <lambda>zOption.<lambda>1   s    1r"   )stringintfloatanybooldicttuplec                     || _         |j                  d      xs d| _        |j                         D ]  \  }}t	        | ||        y )Nr   r'   )defaultgetr   r   setattr)selfr/   argskwargsattrvalues         r   __init__zOption.__init__4   s>    JJv&2(	!<<>KD%D$& *r"   c                 @     | j                   | j                     |      S r   )typemapr   )r2   r6   s     r   	to_pythonzOption.to_python:   s    &t||DII&u--r"   c                 N    dj                  | j                  | j                        S )Nz <Option: type->{} default->{!r}>)r   r   r/   )r2   s    r   __repr__zOption.__repr__=   s$    1889=G 	Gr"   r   )__name__
__module____qualname____doc__altdeprecate_by	remove_bysetr   strr(   r)   r   r,   r-   r9   r7   r:   r<   r   r"   r   r   r   *   sC    2
CLI
%CS5 $@G'.Gr"   r   accept_contentlist)r   r   result_accept_content)r   
enable_utcTr+   importsr   r-   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)r/   r   
pool_limit
   use_sslhostportuserpasswordvhostcachecelery_cache)r   backendbackend_options	cassandra)	entry_ttlkeyspacerl   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   rZ   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dbrk   max_connectionsusernamern   rl   socket_timeoutsocket_connect_timeoutretry_on_timeoutsocket_keepaliveresultr   celery_resultrr   	cache_maxcelery_max_cached_resultscompressionrE   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)rU   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=|j                   D cg c]'  }|j                  |      j                         | |z   |f) c}S | |z   j                         | |z   |fgS c c}w r   )r   r   upper)r    r   r   oldkeys       r   
_to_compatr>  j  so    
ww ''
 ]]3%%'c37
 	
 3hc3/00	
s   ,A$c              #     K   t        || fg      }|rk|j                         \  }}|j                         D ]A  \  }}t        |t              r|j                  ||z   dz   |f       0 ||||      E d{    C |rjyy7 w)zFlatten settings._N)r   popleftr   
isinstancer,   append)droot	keyfilterstackr    r   r   r   s           r   r
   r
   s  s{     D!9+E
mmoGHC#t$b3hnc23$Rc222	 (  3s   A1B3A?4B=B)rF  c           	         ddl m} t        t              D ]g  \  }}|j                  s|j
                  st        | |d       s-|j                  d|d|j                  |j
                  d|j                   d       i | S )Nr   )
deprecatedzThe z settingzUse the z instead)descriptiondeprecationremovalalternative)	celery.utilsrI  r
   r	   rB   rC   getattrwarnrA   )sourcerI  namer   s       r   find_deprecated_settingsrS    sv    'Z(	c7643NOO$thh(?(+(8(8$'MM*2377)8(D  F ) Mr"   )maxsizec           	      D   |j                         }	 t        || j                         t        |   | j                                  S # t        $ r t        j	                         D ]  \  }}|j                         | j                         k(  rt        d||      c cY S t        |t              sI	 t        || j                         || j                                  c cY S # t        $ r Y w xY w Y nw xY wt        d| j                         t        | j                                  S )zFind setting by name.N)lowerr   r	   KeyErrorr   rB  r,   DEFAULTS)rR  r   r    optss       r   r   r     s     !Itzz|Z	%:4::<%H
 	
  	"((*HBxxzTZZ\)#D"d33D$''DJJL$tzz|:LMM  +	 djjlHTZZ\,BCCs<   2A AC/C/,+CC/	C(%C/'C((C/.C/r   )r   )+r@   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:  r>  r
   r/   rX  rG   __compat_OLD_DEFAULTS_TO_OLD_KEY_TO_NEW_KEYrD   keysSETTING_KEYS_OLD_SETTING_KEYSrS  r   )r   r   old_keyr@  new_keys   00000r   <module>rq     s   / )  + 0
5 " 	EG +  #   .*FGG G0  a0v6Ja F3a d(a 2G0	a
 2G0a v.a 
 1(:; !67!%(%d5	
a"  4h'8, H- h'	
 !&1 "!'2  62 %+4f$=  &c6 #5v6 !H5 5) #3U3 Dx0 ,2(+R  "5)!" u6*#& "'( )* "+, X&-. (#/#aT ~&r/	Ua` g&X&"X.F#)(# h/(+)r'aaz (+ h/8$h'*8${aJ hX6"("7#AE2!!%0(+!"51Ce,Ka\ 	8$H%(+17#		]ah W-T0x0iar )*62sa| ()62}aD '(V,EaN Zh7{: :!!%0"2E2Oa\ ~&T07+J'&>
2]an ~&F+u"E*X&X&e'2%d9F3F3oaL  ' H% 89
	 & ( X& 1;<
 $V,  F+!" &>#$ #)&"9%& $Cg6'( "#G4)* .4E-F+, #5<g>-. /5Re.D/0 $E71Ma@ -.V,&G$ F3AaP ())x(!)-H=Qab -./<=
 $%L$M
 &)-J,KL%d8caz 
 3
3
V,3
 $*$V#<3
 E/	3

 &3
 /K.LM3
 %T73
 !'u6 :3
 %QX63
 X&3
 ")(;3
  843
 %X.3
 #4h73
 "x03
   84!3
"  %I$J
#3
( U0)3
* "%f5+3
, ,B+CD-3
. v$?#@
/3
4 $ !# @A
53
B 6"C3
D "$U3E3
F %&1G3
H !V4I3
J 5!K3
L %B$C
M3
R &'?&@AS3
T =>
U3
Z 89
[3
` &,E%?a3
b U0c3
d (.e&'Ae3
{ab  //T)/ >?/ 6<6
	/ %Sw7/ &,E%?/ 4e,/ 9I/ e&/E.FG/ #%A$B
/ &,&
/$ %v$B#C
%/* "$V4+/, f%-/. 12//0 G2L1MN1/2 $/3/4 #.5/6 L!7/8 T/9/: U0;/< "#G4=/> #151?/@ )/t&(AA/B  v$=#>
C/H  &;< 
I/N  %9$:
O/T U/V 34W/X (#Y/Z s1[/\ $Dv6]/ca
H	1 - 	3 &-Z%8!cC 
j9:=EFF/'1c#++%F;CDD$7GWawD;CDD$7GWawD8==?#((*+  	D D3 GDDs   3e8$e>f f