U Z+d1%@sdZddlZddlZddlZddlmZddlmZddlmZddl m Z m Z m Z m Z mZddlmZddlmZdd lmZmZmZmZdd lmZdd lmZmZmZeeZGd d d eZ Gdddej!Z"GdddeZ#GdddeZ$e Z%e"Z&e#Z'e$Z(ej)*dZ+doddZ,ej-e ddidej.ddeede e'dddej.d d!e dddd"d#ej.d$d%e e/d&d'dd(d)ej.d*d+d,e e dd-dej.d.d/d0e e!d1dd2dej.d3e0d4d5d'e dd6d7ej.d8d9e0d:d;d'e dd?d@e&e d, c Cs|d}t|dkr,|dt|dt|dkrtzt|ddf}Wn&tk rr|d|dYnXzttttt|WStk r|d| ddYnXdS) N,z9Expected two comma separated integers or one integer.Got z instead.rzExpected an integer. Got z*Expected two comma separated integers.Got ) splitlenrint ValueErrortuplereversedsortedmapjoinrrrrrRs   zAutoscale.convertNr rrrrr6Msr6 C_FAKEFORKFc Cstrdn|}t|| }t|||||||ddz0| dk r>| }t||g|tWW5QRStk r| dkrddlm} | } | j j d|| dt j d d |g|d d tYW5QRSXW5QRXdS) zDetach program by argv.r9F)Z after_forkersNr) current_appERROR)r4z Can't exec %r T)exc_info)rCrrosexecvr ExceptionceleryrDlogZsetup_logging_subsystemloggercriticalrBr ) pathargvlogfilepidfileuidgidumaskworkdirZfaker executabler4rDrrrdetachns.   rXZallow_extra_argsT)clsZcontext_settingsz-nz --hostnamezWorker Optionsz]Set custom hostname (e.g., 'w1@%%h'). Expands: %%h (hostname), %%n (name) and %%d, (domain).)defaultrYr. help_grouphelp-D--detachz%Start worker as a background process.)rYis_flagrZr[r\z-Sz --statedbcCs|p|jjjjSr5)rrr0Zworker_state_dbr_rrrrsrbzPPath to the state database. The extension '.db' may be appended to the filename.)rYr.callbackr[r\z-lz --loglevelWARNINGzLogging level. optimizationz-OrZ)rZZfairzApply optimization profile.z--prefetch-multiplierzcCs|p|jjjjSr5)rrr0Zworker_prefetch_multiplierr`rrrrbsz>Set custom prefetch multiplier value for this worker instance.)r.metavarrcrYr[r\z-cz --concurrencyz cCs|p|jjjjSr5)rrr0Zworker_concurrencyr`rrrrbsz Pool OptionszlNumber of child processes processing the queue. The default is the number of CPUs available on your system.z-Pz--poolr,zPool implementation.)rZr.rYr[r\z-Ez --task-eventsz--eventszdSend task-related events that can be captured by monitors like celery events, celerymon, and others.)r_rZrYr[r\z --time-limitz;Enables a hard time limit (in seconds int/float) for tasks.)r.rYr[r\z--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_rYr[z--queuesz-Q)r.rYr[z--exclude-queuesz-Xz --includez-Iz--without-gossipZFeaturesz--without-minglez--without-heartbeatz--heartbeat-intervalz --autoscalez-Bz--beatzEmbedded Beat Options)r.rYr_r[z-sz--schedule-filenamez --schedulecCs|p|jjjjSr5)rrr0Zbeat_schedule_filenamer`rrrrb#s)rcrYr[z --scheduler)rYr[c Ksxz0|jj}|jrbz|j|jddWn:ttfk r`} ztjd| |dW5d} ~ XYnX| ddrdd gt j d d} d | kr| d d | kr| d t t j | ||||| d d| dd|| dd|d WSt||d|jf||||t||t| ||jj|jjd| } | | jWStk rr} z |j| jd|d W5d} ~ XYnXdS)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: )rNrXFz-mrKr9r^r]rUrVrW) rQrRrSrTrUrVrrWr4)rSrT)r4pool_clsloglevelrQrRstatedbno_colorquietr)rrargsZconfig_from_cmdlineKeyErrorr=clickZ UsageErrorgetsysrPremoverXrWrZWorkerrrlrmstartexitcoder errorexit)rr4rirrSrTrjrQrRrkkwargserPrgrrrrgs^1       rg) NNNNNNFNNN) NNNNNNNNN)4r$rHrrrprZ click.typesrrKrZcelery.bin.baserrrrr Zcelery.concurrency.baser Zcelery.exceptionsr Zcelery.platformsr r rrZcelery.utils.logrZcelery.utils.nodenamesrrrr!rMrZChoicer&r3r6Z CELERY_BEATZ WORKERS_POOLHOSTNAMEZ AUTOSCALEenvironrqrCrXcommandoptionPathr<floatZ pass_contextrgrrrrs