> iV2 dZddlZddlZddlZddlmZddlmZddlmZddl m Z m Z m Z m Z mZddlmZddlmZdd lmZmZmZmZdd lmZdd lmZmZmZeeZGd d eZ GddejBZ"GddeZ#GddeZ$e Z%e"Z&e#Z'e$Z(ejRjUdZ+ dldZ,ejZe 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 ejBd/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 dbjejde dmdkZ3y)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_formatceZdZdZdZdZy) CeleryBeatzCelery Beat flag.beatcl|jjjr|r|jd|S)NzR-B option does not work on Windows. Please run celery beat as a separate service.)objapp IS_WINDOWSfailselfvalueparamctxs m/var/www/html/wine-match-dev/backend/winematch-backend/venv/lib/python3.12/site-packages/celery/bin/worker.pyconvertzCeleryBeat.converts/ 77;; ! !e IIF G N__name__ __module__ __qualname____doc__namer#r$r"rrs Dr$rc0eZdZdZdZfdZfdZxZS) WorkersPoolzWorkers pool option.poolcHt|tjy)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$cVt|trt|tr|St||||}|j jjj}|dk(r|rtj|}|Stj|}|stj|}|S)Nprefork) isinstancetype issubclassr r0r#rrconf worker_poolrget_implementation)rrr r!r:r3s r"r#zWorkersPool.convert,s eT "z%'BLuc2ggkk&&22 I + 22;?E  2259E#66{C r$)r&r'r(r)r*r1r# __classcell__)r3s@r"r-r-#s DAr$r-ceZdZdZdZdZy)HostnamezHostname option.hostnamec*tt|SN)rrrs r"r#zHostname.convertGs+E233r$Nr%r+r$r"r>r>Bs D4r$r>ceZdZdZdZdZy) AutoscalezAutoscaling parameter.z, c |jd}t|dkDr|jdt|dt|dk(r t|ddf} t t ttt|S#t$r|jd|dYLwxYw#t$r'|jd|jddYywxYw) 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.convertPs C  u:> II ZL 3 4 u:? HU1X* 9&S%"9:; ;  H 5eWIFG H  9 II"ZZ_-Y8 9 9s$ B *B- B*)B*--CCNr%r+r$r"rCrCKs )D9r$rC C_FAKEFORKFc trdn|}t|| }t|||||||d5 | | }tj||g|zt cdddS#t $re| ddlm} | } | jjd|| tjd d j|g|zd tcYcdddSwxYw#1swYyxYw) 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"detachrjls1D '8,G '7CeWd % ' %! HHTD6D= )  {.! GG + +8 , 5 OOOSXXtftm-D%)  +  s)C #AA"C;C CC  Callow_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 --statedbc^|xs*|jjjjSrA)rrr9worker_state_dbr!_rs r"rxs#>cggkk..>>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-multiplierzc^|xs*|jjjjSrA)rrr9worker_prefetch_multiplierrvs r"rxrxs#Icggkk..IIr$z>Set custom prefetch multiplier value for this worker instance.)r7metavarryrlrorpz-cz --concurrencyz c^|xs*|jjjjSrA)rrr9worker_concurrencyrvs r"rxrxs#Acggkk..AAr$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 --schedulec^|xs*|jjjjSrA)rrr9beat_schedule_filenamervs r"rxrx!s#Ecggkk..EEr$)ryrlroz --scheduler)rlroc  H |jj}|jr |j|jd| jddrdd gtjd dz} d | vr| jd d | vr| jd d | vr| jd d| vr| jdttj| ||||| jdd| jdd|| jdd| St|||jd||||t!||t!| ||jj"|jj$d| } | j'|j)| j*y#tt f$r} t jd| |d} ~ wwxYw#t,$rC} |jj/| jd|j)d Yd} ~ yd} ~ 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"rrsf-ggkk 88 -''H'E ::h &(#chhqrl2DT! J't| D!$ G$$ G$#..")")!s & 7D 9"(**Y"=!%+ZZ d%C#+ - - #3/822WW%%''--    !Kj) -&& c#(+-- -L   affQi   sB"GF$CGBG$G3G  GG H!9HH!) 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"rs5 '55,+OO'MM H   %,,>449 92l } : K ZZ^^L ) 8B>22 2 ' ' ' % % * * * * ) D 8 8B+ '02%0<Mr$