a xdL1%@stdZddlZddlZddlZddlmZddlmZddlmZddl m Z m Z m Z m Z mZddlmZddlmZmZmZmZdd lmZdd lmZmZmZeeZGd d d eZGd ddejZ GdddeZ!GdddeZ"eZ#e Z$e!Z%e"Z&ej'(dZ)dnddZ*ej+e ddidej,ddeede e%dddej,dd e dddd!d"ej,d#d$e e-d%d&dd'd(ej,d)d*d+e e dd,dej,d-d.d/e ed0dd1dej,d2e.d3d4d&e dd5d6ej,d7d8e.d9d:d&e d;dd?e$e d;d@dAej,dBdCdDde d;dEdFej,dGe/e d;dHdIej,dJe/e d;dKdIej,dLe.e d;dMdIej,dNe.e d;dOdIej,dPdQde dRdSej,dTdUe e dRdVej,dWdXe e dRdVej,dYdZe e dRdVej,d[de d\dSej,d]de d\dSej,d^de d\dSej,d_e.e d\dVej,d`e&e d\dVej,dadbe#e ddcddej,dedfdgdhd&e dcdiej,dje dcdkej0edodldmZ1dS)pz/Program used to start a Celery worker instance.N) ParamType)StringParamType) concurrency)COMMA_SEPARATED_LIST LOG_LEVELCeleryDaemonCommand CeleryOptionhandle_preload_options) SecurityError) EX_FAILUREEX_OKdetachedmaybe_drop_privileges) get_logger)default_nodename host_format node_formatc@seZdZdZdZddZdS) CeleryBeatzCelery Beat flag.ZbeatcCs|jjjr|r|d|S)NzR-B option does not work on Windows. Please run celery beat as a separate service.)objappZ IS_WINDOWSfailselfvalueparamctxrI/var/www/html/Ranjet/env/lib/python3.9/site-packages/celery/bin/worker.pyconverts zCeleryBeat.convertN__name__ __module__ __qualname____doc__namerrrrrrsrcs0eZdZdZdZfddZfddZZS) WorkersPoolzWorkers pool option.poolcsttdS)z=Initialize the workers pool option with the relevant choices.N)super__init__rZget_available_pool_names)r __class__rrr()szWorkersPool.__init__csPt|||}|jjjj}|dkr4|r4t|}nt|}|sLt|}|S)Nprefork)r'rrrconf worker_poolrZget_implementation)rrrrr-r)rrr-s     zWorkersPool.convert)r r!r"r#r$r(r __classcell__rrr)rr%$s r%c@seZdZdZdZddZdS)HostnamezHostname option.hostnamecCs tt|SN)rrrrrrrEszHostname.convertNrrrrrr/@sr/c@seZdZdZdZddZdS) AutoscalezAutoscaling parameter.z, c Cs|d}t|dkr,|dt|dt|dkrrzt|ddf}Wn$typ|d|dYn0zttttt|WSty|d| ddYn0dS) N,z9Expected two comma separated integers or one integer.Got z instead.rzExpected an integer. Got z*Expected two comma separated integers.Got ) splitlenrint ValueErrortuplereversedsortedmapjoinrrrrrNs       zAutoscale.convertNrrrrrr2Isr2 C_FAKEFORKFc Cstrdn|}t|| }t|||||||ddz2| dur>| }t||g|tWWdSty| durddlm} | } | j j d|| dt j d d |g|d d tYWdS0Wdn1s0YdS) zDetach program by argv.r5F)Z after_forkersNr) current_appERROR)r0z Can't exec %r T)exc_info)r?rr osexecvr Exceptionceleryr@logZsetup_logging_subsystemloggercriticalr>r ) pathargvlogfilepidfileuidgidumaskworkdirZfaker executabler0r@rrrdetachjs*    rTZallow_extra_argsT)clsZcontext_settingsz-nz --hostnamezWorker Optionsz]Set custom hostname (e.g., 'w1@%%h'). Expands: %%h (hostname), %%n (name) and %%d, (domain).)defaultrUtype help_grouphelp-D--detachz%Start worker as a background process.)rUis_flagrVrXrYz-Sz --statedbcCs|p|jjjjSr1)rrr,Zworker_state_dbr_rrrrsr_zPPath to the state database. The extension '.db' may be appended to the filename.)rUrWcallbackrXrYz-lz --loglevelWARNINGzLogging level. optimizationz-OrV)rVZfairzApply optimization profile.z--prefetch-multiplierzcCs|p|jjjjSr1)rrr,Zworker_prefetch_multiplierr]rrrr_sz=Set custom prefetch multiplier valuefor this worker instance.)rWmetavarr`rUrXrYz-cz --concurrencyz cCs|p|jjjjSr1)rrr,Zworker_concurrencyr]rrrr_sz Pool OptionszkNumber of child processes processing the queue. The default is the number of CPUs availableon your system.z-Pz--poolr+zPool implementation.)rVrWrUrXrYz-Ez --task-eventsz--eventszdSend task-related events that can be captured by monitors like celery events, celerymon, and others.)r\rUrXrYz --time-limitz;Enables a hard time limit (in seconds int/float) for tasks.)rWrUrXrYz--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)r\rUrXz--queuesz-Q)rWrUrXz--exclude-queuesz-Xz --includez-Iz--without-gossipZFeaturesz--without-minglez--without-heartbeatz--heartbeat-intervalz --autoscalez-Bz--beatzEmbedded Beat Options)rWrUr\rXz-sz--schedule-filenamez --schedulecCs|p|jjjjSr1)rrr,Zbeat_schedule_filenamer]rrrr_s)r`rUrXz --scheduler)rUrXc Ks|z2|jj}|jrdz|j|jddWn<ttfyb} z tjd| |dWYd} ~ n d} ~ 00| ddrdd gt j d d} d | vr| d d | vr| d t t j | ||||| d d| dd|| dd|d WSt||d|jf||||t||t| ||jj|jjd| } | | jWStyv} z(|j| jd|d WYd} ~ n d} ~ 00dS)aStart 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: )rNrTFz-mrGr5r[rZrQrRrS) rMrNrOrPrQrRrrSr0)rOrP)r0pool_clsloglevelrMrNstatedbno_colorquietr)rrargsZconfig_from_cmdlineKeyErrorr9clickZ UsageErrorgetsysrLremoverTrSrZWorkerrrirjstartexitcoder errorexit)rr0rfrrOrPrgrMrNrhkwargserLrdrrrrds\0       rd) NNNNNNFNNN) NNNNNNNNN)2r#rDrormrZ click.typesrrGrZcelery.bin.baserrrrr Zcelery.exceptionsr Zcelery.platformsr r r rZcelery.utils.logrZcelery.utils.nodenamesrrrr rIrZChoicer%r/r2Z CELERY_BEATZ WORKERS_POOLHOSTNAMEZ AUTOSCALEenvironrnr?rTcommandoptionPathr8floatZ pass_contextrdrrrrs