
    xai>                        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d8d       ed8d       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d8d       ed8d       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dd#      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      d ed8d      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        e/var/www/html/BankruptcyAI-uat/bankruptcy-ai/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"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queue_exclusivequeue_durable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_prefixr   r   
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create_missing_queue_typeclassic"create_missing_queue_exchange_typeinherit_parent_prioritydefault_delivery_modedefault_queuedefault_queue_type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eta_task_limitenable_prefetch_count_reductiondisable_prefetch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@  n  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_compatrD  r  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     D!9+E
mmoG 	3HC#t$b3hnc23$Rc222		3  3s   A1B3A?4B=B)rL  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.utilsrO  r
   r	   rB   rC   getattrwarnrA   )sourcerO  namer   s       r   find_deprecated_settingsrY    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   rH  r,   DEFAULTS)rX  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@  rD  r
   r/   r^  rG   __compat_OLD_DEFAULTS_TO_OLD_KEY_TO_NEW_KEYrD   keysSETTING_KEYS_OLD_SETTING_KEYSrY  r   )r   r   old_keyrF  new_keys   00000r   <module>rw     sx   / )  + 0
5 " 	EG +  #   .*FGG G0  i0v6Ji F3i d(i 2G0	i
 2G0i v.i 
 1(:; !67!%(%d5	
i"  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&-. (#/#iT ~&r/	Ui` g&X&"X.F#)(# h/(+)r'aiz (+ h/8$h'*8${iJ hX6"("7#AE2!!%0(+!"51Ce,Ki\ 	8$H%(+17#		]ih W-T0u62U0x0iiv )*62wi@ ()62AiH '(V,IiR Zh7{: :!!%0"2E2Si` ~&T07+J'u62U0&>
2
aiv ~&F+u"E*X&X&e'2%d9F3F3wiT  ' H% 89
	 & ( X& 1;<
 $V,  F+!" &>#$ #)&"9%& $Cg6'( "#G4)* .4E-F+, #5<g>-. /5Re.D/0 $E71UiH -.V,&G$ F3IiX ())x(!)-H=Yij -./<=
 $%L$M
 &)-J,KL%d8kiB 
 5
5
V,5
 $*$V#<5
 E/	5

 &5
 /K.LM5
 %T75
 #)"B5
 ,2$X+F5
 !'u6 :5
 %QX65
 X&5
 ")(;5
  845
 %X.5
  #4h7!5
" "x0#5
$  84%5
&  %I$J
'5
, U0-5
. "%f5/5
0 ,B+CD15
2 v$?#@
35
8 $ !# @A
95
F 6"G5
H "$U3I5
J %&1K5
L !V4M5
N 5!O5
P %B$C
Q5
V &'?&@AW5
X =>
Y5
^ 89
_5
d &,E%?e5
f U0g5
h (.e&'Ai5
Cin  11T)1 >?1 6<6
	1 %Sw71 &,E%?1 4e,1 9I1 e&/E.FG1 #%A$B
1 &,&
1$ %v$B#C
%1* "$V4+1, f%-1. 12/10 G2L1MN112 $/314 #.516 L!718 T/91: U0;1< "#G4=1> #151?1@ d/A1B )/t&(AC1D  F3E1F  v$=#>
G1L  &;< 
M1R  %9$:
S1X Y1Z 34[1\ (#]1^ s1_1` $Dv6a1oi
X	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   g7gg3g 