o hV2 @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|dkr9z t|ddf}Wnty8|d|dYnwz ttttt|WSty[|d| ddYdSw) N,z9Expected two comma separated integers or one integer.Got z instead.rzExpected an integer. Got z*Expected two comma separated integers.Got ) splitlenrint ValueErrortuplereversedsortedmapjoinrr r r!r"Ps$     zAutoscale.convertNr#r r r r!r<Kr)r< C_FAKEFORKFc Cstrdn|}t|| }t|||||||ddPz| dur| }t||g|tWWdStyf| durDddlm} | } | j j d|| dt j d d |g|d d tYWdSw1sjwYdS) zDetach program by argv.r?F) after_forkersNr) current_appERROR)r:z Can't exec %r T)exc_info)rIrrosexecvr ExceptionceleryrKlogsetup_logging_subsystemloggercriticalrHr ) pathargvlogfilepidfileuidgidumaskworkdirfaker executabler:rKr r r!detachls2    raallow_extra_argsT)clscontext_settingsz-nz --hostnamezWorker Optionsz]Set custom hostname (e.g., 'w1@%%h'). Expands: %%h (hostname), %%n (name) and %%d, (domain).)defaultrcr3 help_grouphelp-D--detachz%Start worker as a background process.)rcis_flagrerfrgz-Sz --statedbcC|p|jjjjSr;)rrr5worker_state_dbr_rr r r!rozPPath to the state database. The extension '.db' may be appended to the filename.)rcr3callbackrfrgz-lz --loglevelWARNINGzLogging level.z-Oz--optimizationre)refairzApply optimization profile.z--prefetch-multiplierzcCrkr;)rrr5worker_prefetch_multiplierrmr r r!rorpz>Set custom prefetch multiplier value for this worker instance.)r3metavarrqrcrfrgz-cz --concurrencyz cCrkr;)rrr5worker_concurrencyrmr r r!rorpz Pool OptionszlNumber of child processes processing the queue. The default is the number of CPUs available on your system.z-Pz--poolr1zPool implementation.)rer3rcrfrgz-Ez --task-eventsz--eventszdSend task-related events that can be captured by monitors like celery events, celerymon, and others.)rjrercrfrgz --time-limitz;Enables a hard time limit (in seconds int/float) for tasks.)r3rcrfrgz--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)rjrcrfz--queuesz-Q)r3rcrfz--exclude-queuesz-Xz --includez-Iz--without-gossipFeaturesz--without-minglez--without-heartbeatz--heartbeat-intervalz --autoscalez-Bz--beatzEmbedded Beat Options)r3rcrjrfz-sz--schedule-filenamez --schedulecCrkr;)rrr5beat_schedule_filenamermr r r!ro!rp)rqrcrfz --scheduler)rcrfc Ksz|jj}|jr+z |j|jddWnttfy*} z tjd| |dd} ~ ww| ddr}dd gt j d d} d | vrE| d d | vrN| d d | vrW| d d| vr`| dt t j | ||||| dd| dd|| dd|d WSt||d|jd||||t||t| ||jj|jjd| } | || jWdSty} z|j| jd|d WYd} ~ dSd} ~ ww)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: )rNraFz-mrRr?rirhz--uidz--gidr]r^r`) rYrZr[r\r]r^rr`r:)r[r\)r:pool_clsloglevelrYrZstatedbno_colorquietrr )rrargsconfig_from_cmdlineKeyErrorrCclick UsageErrorgetsysrXremoverar`rWorkerrr~rstartexitexitcoder error)rr:r{rr[r\r|rYrZr}kwargserXryr r r!rysl4         ry) NNNNNNFNNN) NNNNNNNNN)4r'rOrrr click.typesrrRrcelery.bin.baserrrrr celery.concurrency.baser celery.exceptionsr celery.platformsr r rrcelery.utils.logrcelery.utils.nodenamesrrrr$rUrChoicer*r9r< CELERY_BEAT WORKERS_POOLHOSTNAME AUTOSCALEenvironrrIracommandoptionPathrBfloat pass_contextryr r r r!s                F