`fV2 dZddlZddlZddlZddlmZddlmZddlmZddl m Z m Z m Z m Z mZddlmZddlmZdd lmZmZmZmZdd lmZdd lmZmZmZeeZGd d eZ Gddej!Z"GddeZ#GddeZ$e Z%e"Z&e#Z'e$Z(ej)*dZ+ dldZ,ej-e ddiej.ddeede e'ddej.dd e dddd!"ej.d#d$e ej/d%dd&'ej.d(d)d*e e dd+ej.d,d-d.e ej!d/dd0ej.d1e0d2d3e dd45ej.d6d7e0d8d9e d:d;5ej.de&e d:d?@ej.dAdBdCdde d:dDEej.dFe1e d:dGHej.dIe1e d:dJHej.dKe0e d:dLHej.dMe0e d:dNHej.dOdPde dQRej.dSdTe e dQUej.dVdWe e dQUej.dXdYe e dQUej.dZde d[Rej.d\de d[Rej.d]de d[Rej.d^e0e d[Uej.d_e(e d[Uej.d`dae%e ddbcej.dddedfdge dbhej.die dbjej2e dmdkZ3dS)nz/Program used to start a Celery worker instance.N) ParamType)StringParamType) concurrency)COMMA_SEPARATED_LIST LOG_LEVELCeleryDaemonCommand CeleryOptionhandle_preload_options)BasePool) SecurityError) EX_FAILUREEX_OKdetachedmaybe_drop_privileges) get_logger)default_nodename host_format node_formatceZdZdZdZdZdS) CeleryBeatzCelery Beat flag.beatcV|jjjr|r|d|S)NzR-B option does not work on Windows. Please run celery beat as a separate service.)objapp IS_WINDOWSfailselfvalueparamctxs C/var/www/html/env/lib/python3.11/site-packages/celery/bin/worker.pyconvertzCeleryBeat.converts@ 7; ! Ge G IIF G G G N__name__ __module__ __qualname____doc__namer#r$r"rrs. Dr$rc0eZdZdZdZfdZfdZxZS) WorkersPoolzWorkers pool option.poolclttjdS)z=Initialize the workers pool option with the relevant choices.N)super__init__rget_available_pool_names)r __class__s r"r1zWorkersPool.__init__(s* =??@@@@@r$c`t|trt|tr|St |||}|jjjj }|dkr|rtj |}n*tj |}|stj |}|S)Nprefork) isinstancetype issubclassr r0r#rrconf worker_poolrget_implementation)rrr r!r:r3s r"r#zWorkersPool.convert,s eT " " z%'B'B Luc22gk&2 I  +  2;??EE2599E D#6{CC r$)r&r'r(r)r*r1r# __classcell__)r3s@r"r-r-#sa DAAAAAr$r-ceZdZdZdZdZdS)HostnamezHostname option.hostnamec:tt|SN)rrrs r"r#zHostname.convertGs+E22333r$Nr%r+r$r"r>r>Bs. D44444r$r>ceZdZdZdZdZdS) AutoscalezAutoscaling parameter.z, c <|d}t|dkr&|dt|dt|dkrB t|ddf}n)#t$r|d|dYnwxYw t t ttt|S#t$r0|d| ddYdSwxYw) N,z9Expected two comma separated integers or one integer.Got z instead.rzExpected an integer. Got z*Expected two comma separated integers.Got ) splitlenrint ValueErrortuplereversedsortedmapjoinrs r"r#zAutoscale.convertPsQ C   u::>> II3 ZZ333 4 4 4 u::?? HU1X* H H H FeFFFGGGGG H 9&S%"9"9::;; ; 9 9 9 II8"ZZ__888 9 9 9 9 9 9 9s$#A;;#B! B!%;C!!6DDNr%r+r$r"rCrCKs.  )D99999r$rC C_FAKEFORKFc trdn|}t|| }t|||||||d5 | | }tj||g|zt cdddS#t $rq| ddlm} | } | j d|| t d d |g|zd tcYcdddSwxYw#1swxYwYdS) zDetach program by argv.rGF) after_forkersNr) current_appERROR)r?z Can't exec %r T)exc_info)rQrrosexecvr ExceptionceleryrTlogsetup_logging_subsystemloggercriticalrPr ) pathargvlogfilepidfileuidgidumaskworkdirfaker executabler?rTs r"detachrjls $11D '8,,G '7CeWd % ' ' ' %! HTD6D= ) ) )    {......! G + +8 , 5 5 5 OOOSXXtftm-D-D%)  + + +   s/C##A%%A,C C#C  C##C'*C'allow_extra_argsT)clscontext_settingsz-nz --hostnamezWorker Optionsz]Set custom hostname (e.g., 'w1@%%h'). Expands: %%h (hostname), %%n (name) and %%d, (domain).)defaultrlr7 help_grouphelp-D--detachz%Start worker as a background process.)rlis_flagrnrorpz-Sz --statedbc2|p|jjjjSrA)rrr9worker_state_dbr!_rs r"rxs>cgk.>r$zPPath to the state database. The extension '.db' may be appended to the filename.)rlr7callbackrorpz-lz --loglevelWARNINGzLogging level.z-Oz--optimizationrn)rnfairzApply optimization profile.z--prefetch-multiplierzc2|p|jjjjSrA)rrr9worker_prefetch_multiplierrvs r"rxrxsIcgk.Ir$z>Set custom prefetch multiplier value for this worker instance.)r7metavarryrlrorpz-cz --concurrencyz c2|p|jjjjSrA)rrr9worker_concurrencyrvs r"rxrxsAcgk.Ar$z Pool OptionszlNumber of child processes processing the queue. The default is the number of CPUs available on your system.z-Pz--poolr5zPool implementation.)rnr7rlrorpz-Ez --task-eventsz--eventszdSend task-related events that can be captured by monitors like celery events, celerymon, and others.)rsrnrlrorpz --time-limitz;Enables a hard time limit (in seconds int/float) for tasks.)r7rlrorpz--soft-time-limitz;Enables a soft time limit (in seconds int/float) for tasks.z--max-tasks-per-childzfMaximum number of tasks a pool worker can execute before it's terminated and replaced by a new worker.z--max-memory-per-childaMaximum amount of resident memory, in KiB, that may be consumed by a child process before it will be replaced by a new one. If a single task causes a child process to exceed this limit, the task will be completed and the child process will be replaced afterwards. Default: no limit.z--purgez --discardz Queue Options)rsrlroz--queuesz-Q)r7rlroz--exclude-queuesz-Xz --includez-Iz--without-gossipFeaturesz--without-minglez--without-heartbeatz--heartbeat-intervalz --autoscalez-Bz--beatzEmbedded Beat Options)r7rlrsroz-sz--schedule-filenamez --schedulec2|p|jjjjSrA)rrr9beat_schedule_filenamervs r"rxrx!sEcgk.Er$)ryrlroz --scheduler)rlroc  b |jj}|jrP ||jdn2#tt f$r} t jd| |d} ~ wwxYw| ddrdd gtj d dz} d | vr| d d | vr| d d | vr| d d| vr| dttj | ||||| dd| dd|| dd| St|||jd||||t!||t!| ||jj|jjd| } | || jdS#t,$rE} |j| jd|d Yd} ~ dSd} ~ wwxYw)a*Start worker instance.  Examples --------  $ celery --app=proj worker -l INFO $ celery -A proj worker -l INFO -Q hipri,lopri $ celery -A proj worker --concurrency=4 $ celery -A proj worker --concurrency=1000 -P eventlet $ celery worker --autoscale=10,0 worker) namespacez?Unable to parse extra configuration from command line. Reason: )r!NrjFz-mr[rGrrrqz--uidz--gidrfrgri) rbrcrdrerfrgrrir?)rdre)r?pool_clsloglevelrbrcstatedbno_colorquietrr+)rrargsconfig_from_cmdlineKeyErrorrKclick UsageErrorgetsysraremoverjrirWorkerrrrstartexitexitcoder error)r!r?rrrdrerrbrcrkwargserars r"rrs~f-gk 8 - -''H'EEEEj) - - -&# ##(+---- - ::h & & -(#chqrrl2DT!! J'''t|| D!!!$ G$$$$ G$$$#.")")!s & 7D 9 9"(**Y"="=!%+ZZ d%C%C#+ - - - - #3////82222W%'-    !!!!!   afQi     s?G3GA"AA""C5GBG H.):H))H.) NNNNNNFNNN) NNNNNNNNN)4r)rXrrr click.typesrr[rcelery.bin.baserrrr r celery.concurrency.baser celery.exceptionsr celery.platformsr rrrcelery.utils.logrcelery.utils.nodenamesrrrr&r^rChoicer-r>rC CELERY_BEAT WORKERS_POOLHOSTNAME AUTOSCALEenvironrrQrjcommandoptionPathrJfloat pass_contextrr+r$r"rs55 ''''''55555555555555,,,,,,++++++OOOOOOOOOOOO''''''MMMMMMMMMM H          %,>4444444499999 9992jll {}} 8:: IKK Z^^L ) ) 8B>>>2222 22 '' '' '' %% %% ** ** ** ** ) ) DD 88 88BB++ ' '0022%%00<<MM<>>r$