
    h=                        S r SSKJrJr  SSKJr  SSKJr  SSKJ	r	  Sr
SrSrS	R                  5       rS
rSrS1rS1rS1r\" SS5      rGSS jrS r " S S5      r\" S0 S\" \S\S9_S\" SSS9_S\" SSS9_S\" SS \S9_S!\" SS \S9_S"\" S#\S9_S$\" \\" SS%S9\" 0 S&S9\" S'5      \" S(5      \" SS)S9\" S\S9S*9_S+\" S0 S,\" SS#S9_S-\" SS#S9_S.\" SS#S9_S/\" S#S9_S0\" 0 S&S9_S1\" S2S%S9_S3\" SSS9_S4\" SSS9_S5\" S6S)S9_S7\" S8SS9_S9\" SS#S9_S:\" S;S)S9_S<\" S=S)S9_S>\" SS#S9_S?\" S@S#SA9_SB\" SCS)S9_SD\" S8SS9_SE\" S#S9_SF\" S)S9_SG\" S#S9_SH\" S#S9_SI\" S#S9_6_SJ\" \" SK5      \" 5       \" 0 S&S9SL9_SM\" \" S%S9\" S#S9\" S#S9\" S#S9\" SS9\" S#S9\" S#S9\" S#S9\" S#S9\" S#S9\" 0 S&S9SN9_SO\" \" S#S9\" S#S9\" S#S9\" S#S9\" S#S9\" S#S9SP9_SQ\" \" SRS#S9\" SSS)S9\" SSS)S9\" STS)S9\" SUS#S9\" SVS)S9\" S;S)S9SW9_SX\" \" S#S9\" S#S9\" SUS#S9\" SS%S9SY9_SZ\" \" S[S%S9\" S\S%S9\" SRS#S9S]9_S^\" \" S_5      \" SS&S9S`9_Sa\" \" Sb5      \" SS&S9S`9_Sc\" \" Sd5      \" S&S9S`9_Se\" \" SfS#S9\" SgS#S9\" ShS#S9\" SiS)S9\" SjS)S9Sk9_Sl\" \" Sm5      \" SnS%S9\" SoS%S9\" Sp5      \" Sq5      \" SpS#S9Sr9_Ss\" \" St5      \" S&S9\" S)S9\" S#S9\" S)S9\" S#S9\" S#S9\" S)S9\" SuS%S9\" SS%S9\" S8SS9\" S8SS9Sv9_Sw\" S0 Sx\" Sy5      _Sz\" S#S9_S{\" S|S)S}1S9_S~\" SS9_S\" S5      _S\" S5      _S\" \" SS9S%S1S9_S\" SSS9_S\" S8SS9_S\" Sq5      _S\" 0 S&S9_S\" SS%S9_S\" S=S%S9_S\" SS)S9_S\" \" S5      S%S9_S\" SCS)S9_S\" S8SS9_6_S\" \" S5      \" SS9\" S)S9\" S%S9\" SSS9S9_S\" \" S5      \" S#S9\" S#S9\" S#S9\" SS9\" \S#S9S9_S\" \" S1S9\" S&S1S9\" S8SS1S9\" S&S9\" S&S1S9\" SSS9S9_S\" S0 Sx\_S\" S8SS9_S\" SSS9_S\" S8SS9_S\" SS9_S~\" S#S1S9_S\" SSS9_S\" S8SS9_S\" SSS#S9_S\" SR5      _S\" SS#S9_S\" SS#S9_S\" S5      _S\" SS#S9_S\" S#S9_S\" SS#S9_S\" S8SS1S9_S\" S8SS9_S\" S8SS9_S\" SSS)S1S9_S\" SSS1S9_S\" STSSSS.S&S1S9_S\" S&S9_S\" SS)S9_S\" SS9_S\" S8SS9_S\" SS9_S\" S8SS1S9_S\" SqS1S9_S\" S%S1S9_S\" S%S1S9_S\" S8SS9_S\" S8SS9_S\" S8SS9_6_S\" S0 Sx\_S\" SS#S9_S\" S5      _S\" S8SS9_S\" SS%S9_S\" S8SS9_S\" SS)S9_S\" SS#S9_S\" S8SS1S9_S\" S8SS1S9_S\" S8SS9_S\" SSS1S9_S\" SSS9_S\" SS9_S\" \5      _S\" S\S%S1S9_S\" S)S9_S\" S)S9_S\" \5      _S\" SSS9_S\" S8SS9_S\" SS%S9_S\" S2S)S9_S\" SSS9_S\" SSS1S9_S\" SS1S9_S\" S8SS1S9_S\" 5       _S\" \5      _S\" S#S9_S\" SS%S9_S\" SSS9_6_6rS rS rSU\4S jr\" \5       V Vs0 s H  u  pXR<                  _M     snn r\ " \" \\S95      r!\! VVVs0 s H  u  p#oUR<                  _M     snnnr"\! VVVs0 s H  u  p$o4U_M
     snnnr#\! VVVs0 s H  u  p$o2U_M
     snnnr$Sr!\%" \RM                  5       5      r'\%" \$RM                  5       5      r(S r)\" SGS 9GSGS j5       r*gs  snn f s  snnnf s  snnnf s  snnnf (  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                     U bR  UR                  5        H>  u  p#UR                  (       a  M  U  Vs1 s H  oDR                  U5      iM     snUl        M@     U$ s  snf N)itemsoldformat)__old__optionsr   optos        ;D:\TimeStamps\venv\Lib\site-packages\celery/app/defaults.py	Namespacer      sK    HC77729:'Q88C=': ( N ;s   Ac                     U  S31$ )Nz_{0} )nss    r   old_nsr!   &   s    d&M?    c                   ^    \ rS rSrSrSrSrSr\" 5       r	\
\\S \\\S.rS
S jrS rS rS	rg)r   *   z(Describes a Celery configuration option.Nc                     U $ r   r   )vs    r   <lambda>Option.<lambda>1   s    1r"   )stringintfloatanybooldicttuplec                     Xl         UR                  S5      =(       d    SU l        UR                  5        H  u  pE[	        XU5        M     g )Nr   r)   )defaultgetr   r   setattr)selfr1   argskwargsattrvalues         r   __init__Option.__init__4   s8    JJv&2(	!<<>KDD& *r"   c                 @    U R                   U R                     " U5      $ r   )typemapr   )r4   r8   s     r   	to_pythonOption.to_python:   s    ||DII&u--r"   c                 N    SR                  U R                  U R                  5      $ )Nz <Option: type->{} default->{!r}>)r   r   r1   )r4   s    r   __repr__Option.__repr__=   s$    1889=G 	Gr"   r1   r   r   )__name__
__module____qualname____firstlineno____doc__altdeprecate_by	remove_bysetr   strr*   r+   r   r.   r/   r<   r9   r=   r@   __static_attributes__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quorumrB   
pool_limit
   use_sslhostportuserpasswordvhostcachecelery_cache)r   backendbackend_options	cassandra)	entry_ttlkeyspacert   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   rb   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dbrs   max_connectionsusernamerv   rt   socket_timeoutsocket_connect_timeoutretry_on_timeoutsocket_keepaliveresultr   celery_resultrz   	cache_maxcelery_max_cached_resultscompressionrL   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)r]   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                     X-   U4/$ r   r   )r    r   r   s      r   _flatten_keysrB  f  s    XsOr"   c                     UR                   (       a?  UR                    Vs/ s H'  nUR                  U5      R                  5       X-   U4PM)     sn$ X-   R                  5       X-   U4/$ s  snf r   )r   r   upper)r    r   r   oldkeys       r   
_to_compatrF  j  sn    
ww ''
! ]]3%%'37!
 	
 h3/00	
s   .A)c              #   "  #    [        X4/5      nU(       au  UR                  5       u  pEUR                  5        HE  u  pg[        U[        5      (       a  UR                  XF-   S-   U45        M4  U" XFU5       Sh  vN   MG     U(       a  Mt  gg N7f)zFlatten settings._N)r   popleftr   
isinstancer.   append)droot	keyfilterstackr    r   r   r   s           r   r
   r
   s  su     D9+E
mmoHC#t$$bhnc23$Rc222	 ( % 3s   A7B9B:BB)rN  c           	      "   SSK Jn  [        [        5       Hu  u  p#UR                  (       d  UR
                  (       d  M)  [        XS 5      (       d  M<  UR                  SU< S3UR                  UR
                  SUR                   S3S9  Mw     U $ )Nr   )
deprecatedzThe z settingzUse the z instead)descriptiondeprecationremovalalternative)	celery.utilsrQ  r
   r	   rI   rJ   getattrwarnrH   )sourcerQ  namer   s       r   find_deprecated_settingsr[    sw    'Z(	763N3NOO$thh(?(+(8(8$'MM*2377)8(D  F ) Mr"   )maxsizec           	      P   UR                  5       n [        XR                  5       [        U   U R                  5          5      $ ! [         a    [        R	                  5        H  u  p#UR                  5       U R                  5       :X  a  [        SX#5      s  s $ [        U[        5      (       d  MN   [        X R                  5       X0R                  5          5      s  s $ ! [         a     M  f = f    Of = f[        SU R                  5       [        U R                  5          5      $ )zFind setting by name.N)lowerr   r	   KeyErrorr   rJ  r.   DEFAULTS)rZ  r   r    optss       r   r   r     s     !Izz|Z	%:4::<%H
 	
  	"((*HBxxzTZZ\)#D"33D$'''JJL$zz|:LMM  +	 djjlHTZZ\,BCCs<   1A AC5C51)CC5
C-)C5,C--C54C5r   )r   )+rG   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	   rB  rF  r
   r1   r`  rO   __compat_OLD_DEFAULTS_TO_OLD_KEY_TO_NEW_KEYrK   keysSETTING_KEYS_OLD_SETTING_KEYSr[  r   )r   r   old_keyrH  new_keys   00000r   <module>ry     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%8C%8 
j9:=EFX/'c#++%XF;CD8$7Ga8D;CD8$7Ga8D8==?#((*+  	D D3 GDDs   ]0]].]