<#(iddlZddlZddlZddlZddlZddlmZddlmZddlZddl m Z ddl m Z m Z ddl mZddlmZdd lmZdd lmZdd lmZmZmZdd l mZmZdd lmZejeZdZ dZ!ej"eddiej#ddej$ej%dZ&dZ'dZ(dZ)dZ*dZ+dZ,dZ-dZ.dS)N)pformat) NullHandler)options)parse_command_lineparse_config_file)enable_pretty_logging) CeleryCommand)Flower)settings)abs_path prepend_url strtobool)DEFAULT_CONFIG_FILEdefault_options)validate_auth_optionFLOWER_cdtd|tjddS)Nz%s detected, shutting downr)loggerinfosysexit)signum_s N/var/www/html/auto_sub_bot/venv/lib/python3.11/site-packages/flower/command.pysigterm_handlerrs( KK,f555HQKKKKKignore_unknown_optionsT)clscontext_settings tornado_argv)nargstypect||tttjd|t t |jj}td|tdt}tj |jtjtjt"|jjst'|dtv |dS#t*t,f$rYdSwxYw)zAWeb based tool for monitoring and administrating Celery clusters.r)cappr ssl_optionsN)-warn_about_celery_args_used_in_flower_commandapply_env_options apply_optionsrargvextract_settings setup_loggingobjappr rr atexitregisterstopsignalSIGTERMrquiet print_bannerstartKeyboardInterrupt SystemExit)ctxr!r0 flower_apps rflowerr= s2#|DDD#(1+|,,,OOO '+C>S'>>X>>J OJO$$$ M&./222 7=5S-83444  z *     s!C77D  D cftttj}|D] }|t dd}tj|} tj|n6#t$r)tj|ddYnwxYwj r"fd| dD}n@j turtt|}n |}tt||dS)z2apply options passed through environment variablesr r-c:g|]}|Sr()r$).0ioptions r z%apply_env_options..Is#>>>V[[^^>>>r,N)filteris_flower_envvarosenvironreplaceENV_VAR_PREFIXlowerr_optionsKeyErrormultiplesplitr$boolrsetattr) env_options env_var_namenamevaluerDs @rr*r*>s&)2:66K#&& ##NB::@@BB <( >%d+FF > > >%dll3&<&<=FFF > ? +>>>>U[[-=-=>>>EE{d""Yu--.. E**u%%%%&&s'A::0B-,B-cttt|}t|g|z t t jtj dt|g|zdS#t$r7t j tj tkrYdSwxYw)z3apply options passed through the configuration fileF)finalN) listrGis_flower_optionrrrIpathabspathrconfIOErrorbasenamer) prog_namer,s rr+r+Rs '.. / /D {T)***"'//',77uEEEEI;-.....  7  GL ) )-@ @ @  A @ @sA B=CCcd|jjjD}g}|D]4}|d\}}}||vr||5|rt d|dSdS)Nc&g|]}|jD]}|Sr()opts)rBparamrDs rrEzAwarn_about_celery_args_used_in_flower_command..`s)]]]RWR\]]f]]]]r=zYou have incorrectly specified the following celery arguments after flower command: %s. Please specify them after celery command instead following this template: celery [celery args] flower [flower args].)parentcommandparams partitionappendrwarning)r; flower_argscelery_optionsincorrectly_used_argsargarg_namers rr)r)_s]]#**<*C]]]N33s++!Q ~ % % ! ( ( 2 2 2  9;P        rctjr,tjdkrdt_tdStjdt dtjd_dS)Nrdebugztornado.accessF)rrsloggingr getLogger addHandlerr propagater(rrr.r.qso}>F22!*++66{}}EEE8=*++555rctjtd<tjrtjtd<tjr2dD]/}t t|tjt|<0tjrtjptj dtj ptj dtj ptj ddtd<tj rtjrztt!tj t!tj td <tjr't!tjtd d <tjrTt%tjs=t&d tjt+jd dSdSdS)Nrs cookie_secret) login_urlstatic_url_prefixFLOWER_OAUTH2_KEYFLOWER_OAUTH2_SECRETFLOWER_OAUTH2_REDIRECT_URI)keysecret redirect_urioauth)certfilekeyfiler'ca_certszInvalid '--auth' option: %sr )rrsr ry url_prefixrauth oauth2_keyrIrJget oauth2_secretoauth2_redirect_urirrdictr rrrerrorrrrVs rr-r-zs HW:$+$9!M6 M MD($9KLLHTNN| %L8K)L)L+Urz~~>T/U/U#7g2:>>Jf;g;g   MGOM"&9I0J0J/7/H/H#J#J#J   M2:7;K2L2LH] #J /|0>> 2GLAAA  rc|dd\}}}|dd}tt|S)Nr@rfr)lstriprjrKhasattrr)rprVrs rr[r[sHC**3//JD!Q <<S ! !D 7D ! !!rc|to4|ttdtvS)N) startswithrLlenrMrrs rrHrHsB ??> * * > S ! !"((**o=>rc tjsXtjrdtjd}nd}td|rdndtjpdtj|n%tdtjtd|tdtt|j t d ttdS) N/r?zVisit me at http%s://%s:%s%ssz0.0.0.0z!Visit me via unix socket file: %sz Broker: %szRegistered tasks: %sz Settings: %s)r unix_socketrrraddressport connectionas_urirsortedtaskskeysrsr )r0ssl prefix_strs rr7r7s    N   2W/222JJJ *3,>CCB O (y',      79LMMM KK cnn..5577888 KK sy~~''(()) LL!2!233333r)/rIrr1r4rtpprintrrclicktornado.optionsrrr tornado.logrcelery.bin.baser r0r urlsr utilsr rrrr views.authrru__name__rrLrrhargument UNPROCESSED pass_contextr=r*r+r)r.r-r[rHr7r(rrrs0  ######AAAAAAAA------))))))333333333399999999,,,,,,  8 $ $ =+T!bu/@AAA  BA   0&&&(      $>>>8""" >>> 44444r