
    >i:                     2   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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 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      dd       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/html/wine-match-dev/backend/winematch-backend/venv/lib/python3.12/site-packages/celery/app/defaults.py	Namespacer      sN     	;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    1 r"   )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   sC    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
pool_limit
   use_sslhostportuserpasswordvhostcachecelery_cache)r   backendbackend_options	cassandra)	entry_ttlkeyspacerj   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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dbri   max_connectionsusernamerl   rj   socket_timeoutsocket_connect_timeoutretry_on_timeoutsocket_keepaliveresultr   celery_resultrp   	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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_keysr.  Y  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_compatr2  ]  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
   f  s     D!9+E
mmoG 	3HC#t$b3hnc23$Rc222		3  3s   A1B3A?4B=B)r:  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.utilsr=  r
   r	   rB   rC   getattrwarnrA   )sourcer=  namer   s       r   find_deprecated_settingsrG    s}    'Z( F	c7643NOO$thh(?(+(8(8$'MM*2377)8(D  F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   r6  r,   DEFAULTS)rF  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.  r2  r
   r/   rL  rG   __compat_OLD_DEFAULTS_TO_OLD_KEY_TO_NEW_KEYrD   keysSETTING_KEYS_OLD_SETTING_KEYSrG  r   )r   r   old_keyr4  new_keys   00000r   <module>re     s\   / )  + 0
5 " 	EG +  #   .*FGG G0  T0v6JT F3T d(T 2G0	T
 2G0T v.T 
 1(:; !67!%(%d5	
T"  4h'8, H- h'	
 !&1 "!'2  62 %+4f$=  &c6 #5v6 !H5 5) #3U3 Dx0 "5)  u6*!$ "%& '( ")* X&+, (#-#TR ~&r/	ST^ g&X&"X.F#)(# h/(+)r'_Tx (+ h/8$h'*8$yTH hX6"("7#AE2!!%0(+!"51Ce,ITZ W-T0x0[Td )*62eTn ()62oTv '(V,wT@ Zh7{: :!!%0"2E2ATN ~&T07+J'&>
2OT` ~&F+u"E*X&X&e'2%d9F3F3aT~  ' H% 89
	 & ( X& 1;<
 $V,  F+!" &>#$ #)&"9%& $Cg6'( "#G4)* .4E-F+, #5<g>-. /5Re.D/0 $E71Tr -.V,&G$ F3sTB ())x(!)-H=CTT -./<=
 $%L$M
 &)-J,KL
UTj 
 2
2
V,2
 $*$V#<2
 E/	2

 &2
 /K.LM2
 %T72
 !'u6 :2
 %QX62
 X&2
  842
 %X.2
 #4h72
 "x02
  842
   %I$J
!2
& U0'2
( "%f5)2
* ,B+CD+2
, v$?#@
-2
2 $ !# @A
32
@ 6"A2
B "$U3C2
D %&1E2
F !V4G2
H 5!I2
J %B$C
K2
P &'?&@AQ2
R =>
S2
X 89
Y2
^ &,E%?_2
` U0a2
b (.e&'Ac2
kTP  ++T)+ >?+ 6<6
	+ 4e,+ 9I+ e&/E.FG+ #%A$B
+ &,&
+  %v$B#C
!+& "$V4'+( f%)+* 12++, G2L1MN-+. $//+0 #.1+2 L!3+4 T/5+6 U07+8 "#G49+: #151;+<  v$=#>
=+B  &;< 
C+H  %9$:
I+N O+P 34Q+R (#S+T s1U+QT
n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   <c>-dd)d