h#dZddlZddlZddlmZddlmZddlmZddl m Z ddl Z ddl m Z m Z ddlmZdd lmZdd lmZdd lmZdd lmZdd lmZ ddlmZddlmZddlmZeZ eZ!GddZ#dZ$Gdde jJZ&Gdde jNZ(Gdde&Z)Gdde(Z*Gdde Z+Gdd e Z,Gd!d"e Z-Gd#d$e Z.Gd%d&e Z/Gd'd(e j`Z1e,Z2e-Z3e.Z4e/Z5e1Z6e+Z7y#e"$r dZdZ dZ!YwxYw))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 K/var/www/Befach/backend/env/lib/python3.12/site-packages/celery/bin/base.pyrrscreZdZdZddZedZedZddZddZ ddZ dd Z d Z d Z d Zdd Zy) CLIContextzContext Object for the CLI.cT|xs t|_||_||_||_y)zInitialize the CLI context.N)r appno_colorquietworkdir)selfrrr rs r__init__zCLIContext.__init__%s&+/+    rc*|jdddS)NOKgreenTfgboldstyler!s rr$z CLIContext.OK,szz$7z66rc*|jdddS)NERRORredTr&r)r+s rr-zCLIContext.ERROR0szz'e$z77rNc J|jr|Stj|fi|SN)rclickr*r!messagers rr*zCLIContext.style4s" ==N;;w1&1 1rc |jrd|d<tj|fi|ytj|fi|yNFcolorrr1echosechor2s rr9zCLIContext.secho:s4 ==#F7O JJw )& ) KK *6 *rc |jrd|d<tj|fi|ytj|fi|yr5)rr1r8r2s rr8zCLIContext.echoAs4 ==#F7O JJw )& ) JJw )& )rc d|d<|jrd|d<tj|fi|ytj|fi|y)NTerrFr6r7r2s rerrorzCLIContext.errorHs=u ==#F7O JJw )& ) KK *6 *rct|tr|j|j|fSt|tr`d|vsd|vr|j |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 77D,,Q// / a qyGqL0033JJqD;}}!!UI6Awwz! a 77A: ww ""rc>|sydjfd|DS)Nz - empty - c3NK|]}jddd|yw)*white)r' Nr)).0itemr!s r z)CLIContext.pretty_list..bs/ 8.callerzsggkk+.+;+;+?+? 2+NOa166OO '6"~ 66L ! % %QC N&t&v&&Ps B B r)rwrxs` rhandle_preload_optionsryxs ' &! $$rc,eZdZdZfdZfdZxZS) CeleryOptionzCustomized option for Celery.c~|jr|j|j|_t||g|i|Sr0)default_value_from_contextrndefaultsuper get_default)r!rsrr __class__s rrzCeleryOption.get_defaults<  * *774#B#BCDLw"38888rc|jdd|_|jdd|_t||i|y)zInitialize a Celery option. help_groupNr})poprr}rr"r!rrrs rr"zCeleryOption.__init__s< **\48*0**5QSW*X' $)&)r)rerfrgrhrr" __classcell__rs@rr{r{s'9 **rr{ceZdZdZdZy) CeleryCommandzCustomized command for Celery.ct}|j|D]}|j|}|t|drA|jr5|j t |jgj|d|j dgj||jD]0\}}|j|5|j|ddd2y#1swY=xYw)z7Write all the options into the formatter if they exist.NrOptions) r get_paramsget_help_recordhasattrr setdefaultrLappenditemssectionwrite_dl)r!rs formatteroptsparamrvrq opts_groups rformat_optionszCeleryCommand.format_optionss}__S)E&&s+B~5,/E4D4DOOC(8(8$92>EEbIOOIr299"= *!% D*""4( /"":. / /!- / /s C''C0 N)rerfrgrhrrrrrrs ( /rrc:eZdZdZfdZdedededefdZxZ S) DaemonOptionzCommon daemonization optionct||f|jdd|jd|jd|y)NrzDaemonization Optionscallback)rr)rr"rdaemon_settingrs rr"zDaemonOption.__init__sD  #$*JJ|=T$U"(**Z9L9L"M #" #rrsoptvaluereturnc|xsNt|jjj|jj d|j dS)z Try to fetch daemonization option from applications settings. Use the daemon command name as prefix (eg. `worker` -> `worker_pidfile`) _N)getattrrnrconfcommandrq)r!rsrrs rrzDaemonOption.daemon_settingsA Z 0 0S[[5E5E4Fa {2SUYZZr) rerfrgrhr"rr{rrrrs@rrrs1%# ['[ [S[S[rrc"eZdZdZfdZxZS)CeleryDaemonCommandzDaemon commands.c t||i||jjt dddt ddt ddt d d t d d t d dfy)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__sp $)&)  d1V W +S T 'I J 'J K )W X .V W   r)rerfrgrhr"rrs@rrrs   rrceZdZdZdZdZy)CommaSeparatedListzComma separated list argument.zcomma separated listc,tj|Sr0)r str_to_list)r!rrrss rconvertzCommaSeparatedList.converts&&rNrerfrgrhrqrrrrrrs( !D'rrceZdZdZdZdZy) JsonArrayzJSON formatted array argument.z json arrayct|tr|S tj|}tts|j |d|S#t$r$}|j t |Yd}~Nd}~wwxYw)Nz was not an array)rCrDrHloads ValueErrorfailrLr!rrrsves rrzJsonArray.convertsn eT "L  5!A!T" II01 2   IIc!f   A A<A77A<Nrrrrrrs( D rrceZdZdZdZdZy) JsonObjectzJSON formatted object argument.z json objectct|tr|S tj|}tts|j |d|S#t$r$}|j t |Yd}~Nd}~wwxYw)Nz was not an object)rCrFrHrrrrLrs rrzJsonObject.convertsn eT "L  5!A!T" II12 3   IIc!f   rNrrrrrrs) D rrceZdZdZdZdZy)ISO8601DateTimezISO 8601 Date Time argument.z iso-86091ct t|S#ttf$r}|j|Yd}~yd}~wwxYwr0)r TypeErrorrrr!rrrsrs rrzISO8601DateTime.converts4  ' ':&  IIaLL s 727Nrrrrrrs& DrrceZdZdZdZdZy)ISO8601DateTimeOrFloatz%ISO 8601 Date Time or float argument.ziso-86091 or floatc t|S#ttf$rYnwxYw t|S#ttf$r}|j |Yd}~yd}~wwxYwr0)floatrrrrrs rrzISO8601DateTimeOrFloat.convertsZ < :&     ' ':&  IIaLL s  .AAANrrrrrr s/ D rrc,eZdZdZfdZfdZxZS)LogLevelzLog level option.c$t|dy)z:Initialize the log level option with the relevant choices.)DEBUGINFOWARNINGr-CRITICALFATALN)rr")r!rs rr"zLogLevel.__init__ s STrct|tjr|S|j}t||||}t |Sr0)rCnumbersIntegralupperrrr)r!rrrsrs rrzLogLevel.convert$s? eW-- .L uc2e}r)rerfrgrhr"rrrs@rrrsUrr)8rhrHr collectionsr functoolsrpprintrtypingrr1rr kombu.utils.objectsr celery._stater celery.signalsr celery.utilsr celery.utils.logrcelery.utils.timerpygmentsrpygments.formattersrpygments.lexersrrJrK ImportErrorrryOptionr{CommandrrrrrrrrChoicer JSON_ARRAY JSON_OBJECTISO8601ISO8601_OR_FLOAT LOG_LEVELCOMMA_SEPARATED_LISTrrrrs=& #$ $/)/#+ '"8+ ME$&ISSl%( *5<< */EMM/&[<["  -  '' (( i Y" u||  [ l  )+ J )+w EI sD88 EE