{kf#dZddlZddlZddlmZddlmZddlmZddl m Z ddl Z ddl m Z m Z ddlmZdd lmZdd lmZdd lmZdd lmZdd lmZ ddlmZddlmZddlmZeZ eZ!n#e"$r dZdZ dZ!YnwxYwGddZ#dZ$Gdde j%Z&Gdde j'Z(Gdde&Z)Gdde(Z*Gdde Z+Gdd e Z,Gd!d"e Z-Gd#d$e Z.Gd%d&e Z/Gd'd(e j0Z1e,Z2e-Z3e.Z4e/Z5e1Z6e+Z7dS))z Click customizations for Celery.N) OrderedDictupdate_wrapper)pformat)Any)Context ParamType)cached_property)get_current_app)user_preload_options)text)mlevel) maybe_iso8601) highlight)Terminal256Formatter) PythonLexerc|S)z2Place holder function in case pygments is missing.)sargskwargss O/var/www/html/nettyfy-visnx/env/lib/python3.11/site-packages/celery/bin/base.pyrrsceZdZdZddZedZedZddZddZ dd Z dd Z d Z d Z d ZddZdS) CLIContextzContext Object for the CLI.FcZ|p t|_||_||_||_dS)zInitialize the CLI context.N)r appno_colorquietworkdir)selfrrr rs r__init__zCLIContext.__init__%s-+/++    rc2|dddS)NOKgreenTfgboldstyler!s rr$z CLIContext.OK,szz$7z666rc2|dddS)NERRORredTr&r)r+s rr-zCLIContext.ERROR0szz'e$z777rNc 8|jr|Stj|fi|SN)rclickr*r!messagers rr*zCLIContext.style4s) = 2N;w11&11 1rc j|jrd|d<tj|fi|dStj|fi|dSNFcolorrr1echosechor2s rr9zCLIContext.secho:sQ = +#F7O Jw ) )& ) ) ) ) ) K * *6 * * * * *rc j|jrd|d<tj|fi|dStj|fi|dSr5)rr1r8r2s rr8zCLIContext.echoAsQ = *#F7O Jw ) )& ) ) ) ) ) Jw ) )& ) ) ) ) )rc td|d<|jrd|d<tj|fi|dStj|fi|dS)NTerrFr6r7r2s rerrorzCLIContext.errorHsZu = +#F7O Jw ) )& ) ) ) ) ) K * *6 * * * * *rct|tr|j||fSt|tr_d|vsd|vr||St j|dd}|jst|tt}|j|fSt|tr |j|fS|jt|fS)Nokr=T) sort_keysindent) isinstancelistr$ pretty_listdictpretty_dict_ok_errorjsondumpsrrLEXER FORMATTERstrr)r!nrs rprettyzCLIContext.prettyPs a   07D,,Q/// / a   "qyyGqLL00333JqD;;;}7!!UI66Awz! a   7A: w ""rcN|sdSdfd|DS)Nz - empty - c3PK|] }ddd|V!dS)*white)r' Nr)).0itemr!s r z)CLIContext.pretty_list..bsR  8z:handle_preload_options..caller..}sOOOa16OOOrpreloadc"i|] }|| Srr)rUpreload_optionrs r z:handle_preload_options..caller..s0"~ 6r)senderroptions)objr user_optionsgetr send)ctxrrrpreload_optionsrvfs ` rcallerz&handle_preload_options..callerzsgkOO3+;+?+? 2+N+NOOO  O&5L ! %QC N N N Nq&t&&&v&&&rr)r{r|s` rhandle_preload_optionsr}xs. ' ' ' ' ' &! $ $$rc,eZdZdZfdZfdZxZS) CeleryOptionzCustomized option for Celery.cz|jr|j|j|_tj|g|Ri|Sr0)default_value_from_contextrudefaultsuper get_default)r!ryrr __class__s rrzCeleryOption.get_defaultsG  * D74#BCDL"uww"38888888rc|dd|_|dd|_tj|i|dS)zInitialize a Celery option. help_groupNr)poprrrr"r!rrrs rr"zCeleryOption.__init__sR **\488*0**5QSW*X*X'$)&)))))r)rerfrgrhrr" __classcell__rs@rrrsW''99999 *********rrceZdZdZdZdS) CeleryCommandzCustomized command for Celery.c0t}||D]}||}||t|drC|jr<|t |jg|l|dg||D]G\}}| |5| |dddn #1swxYwYHdS)z7Write all the options into the formatter if they exist.NrOptions) r get_paramsget_help_recordhasattrr setdefaultrLappenditemssectionwrite_dl)r!ry formatteroptsparamrvrl opts_groups rformat_optionszCeleryCommand.format_optionssQ}}__S)) > >E&&s++B~5,//>E4D>OOC(8$9$92>>EEbIIIIOOIr2299"=== $  / / D*""4(( / /"":... / / / / / / / / / / / / / / / / /s(D  D D N)rerfrgrhrrrrrrs)(( / / / / /rrc:eZdZdZfdZdedededefdZxZ S) DaemonOptionzCommon daemonization optionctj|f|dd|d|jd|dS)NrzDaemonization Optionscallback)rr)rr"rdaemon_settingrs rr"zDaemonOption.__init__sd #$*JJ|=T$U$U"(**Z9L"M"M # #" # # # # #rryoptvaluereturncn|p3t|jjj|jjd|jdS)z Try to fetch deamonization option from applications settings. Use the daemon command name as prefix (eg. `worker` -> `worker_pidfile`) _N)getattrrurconfcommandrl)r!ryrrs rrzDaemonOption.daemon_settings8 Z 0S[5E2S2S 2S2SUYZZZr) rerfrgrhr"rrrrrrs@rrrsz%%##### ['[ [S[S[[[[[[[[rrc"eZdZdZfdZxZS)CeleryDaemonCommandzDaemon commands.c 0tj|i||jt dddt ddt ddt d d t d d t d dfdS)z7Initialize a Celery command with common daemon options.z --logfilez-fz#Log destination; defaults to stderr)helpz --pidfilez&PID file path; defaults to no PID filez--uidz Drops privileges to this user IDz--gidz!Drops privileges to this group IDz--umaskz,Create files and directories with this umaskz --executablez&Override path to the Python executableN)rr"paramsextendrrs rr"zCeleryDaemonCommand.__init__s$)&)))  d1V W W W +S T T T 'I J J J 'J K K K )W X X X .V W W W       r)rerfrgrhr"rrs@rrrs>          rrceZdZdZdZdZdS)CommaSeparatedListzComma separated list argument.zcomma separated listc*tj|Sr0)r str_to_list)r!rrrys rconvertzCommaSeparatedList.converts&&&rNrerfrgrhrlrrrrrrs.(( !D'''''rrceZdZdZdZdZdS) JsonArrayzJSON formatted array argument.z json arrayc,t|tr|S tj|}n9#t$r,}|t |Yd}~nd}~wwxYwt|ts||d|S)Nz was not an array)rCrDrHloads ValueErrorfailrLr!rrryves rrzJsonArray.converts eT " " L  5!!AA    IIc!ff         !T"" 3 II111 2 2 2. A$"AA$Nrrrrrrs.(( D     rrceZdZdZdZdZdS) JsonObjectzJSON formatted object argument.z json objectc,t|tr|S tj|}n9#t$r,}|t |Yd}~nd}~wwxYwt|ts||d|S)Nz was not an object)rCrFrHrrrrLrs rrzJsonObject.converts eT " " L  5!!AA    IIc!ff         !T"" 4 II222 3 3 3rNrrrrrrs.)) D     rrceZdZdZdZdZdS)ISO8601DateTimezISO 8601 Date Time argument.z iso-86091c t|S#ttf$r }||Yd}~dSd}~wwxYwr0)r TypeErrorrrr!rrryrs rrzISO8601DateTime.convertsT  '' ':&    IIaLLLLLLLLL sA=ANrrrrrrs.&& DrrceZdZdZdZdZdS)ISO8601DateTimeOrFloatz%ISO 8601 Date Time or float argument.ziso-86091 or floatc t|S#ttf$rYnwxYw t|S#ttf$r }||Yd}~dSd}~wwxYwr0)floatrrrrrs rrzISO8601DateTimeOrFloat.converts << :&    D   '' ':&    IIaLLLLLLLLL s!%%8A) A$$A)Nrrrrrr s.// D     rrc,eZdZdZfdZfdZxZS)LogLevelzLog level option.cJtddS)z:Initialize the log level option with the relevant choices.)DEBUGINFOWARNINGr-CRITICALFATALN)rr")r!rs rr"zLogLevel.__init__s" STTTTTrct|tjr|S|}t |||}t |Sr0)rCnumbersIntegralupperrrr)r!rrryrs rrzLogLevel.convert#sO eW- . . L uc22e}}r)rerfrgrhr"rrrs@rrrs\UUUUUrr)8rhrHr collectionsr functoolsrpprintrtypingrr1rr kombu.utils.objectsr celery._stater celery.signalsr celery.utilsr celery.utils.logrcelery.utils.timerpygmentsrpygments.formattersrpygments.lexersrrJrK ImportErrorrr}OptionrCommandrrrrrrrrChoicer JSON_ARRAY JSON_OBJECTISO8601ISO8601_OR_FLOAT LOG_LEVELCOMMA_SEPARATED_LISTrrrrs&& ######$$$$$$ $$$$$$$$//////))))))//////######++++++ '""""""888888++++++ KMME$$&&II EIII SSSSSSSSl%%%( * * * * *5< * * */////EM///& [ [ [ [ [< [ [ [      -    '''''''' ((     i   Y"     u|    Y[[ jll /  ))++ HJJ ))++sA;; B  B