P'^c @@sRdZddlmZmZddlZddlZddlZddlZddlm Z ddl m Z ddl m Z mZddlmZmZmZmZddlmZdd lmZdd lmZdd lmZmZmZdd lmZdd lm Z ddl!m"Z"ddl#m$Z$ddl%m&Z&ddgZ'dZ(dZ)ej*j+de,Z-dddddddgdfddd d!gd"fd#d$d%d&d'd(d)gdfgZ/e-re/j0d*d+gd,fnd-Z1dd.Z2d/efd0YZ3d1efd2YZ4d3efd4YZ5d5efd6YZ6d7efd8YZ7d9efd:YZ8d;e8fd<YZ9d=e8fd>YZ:d?efd@YZ;dAefdBYZ<dCefdDYZ=dEefdFYZ>dGefdHYZ?dIefdJYZ@dKZAeBdLkrNe2ndS(Mu@ The :program:`celery` umbrella command. .. program:: celery i(tabsolute_importtunicode_literalsN(tpartial(t import_module(tstring_ttvalues(tEX_OKt EX_FAILUREtEX_UNAVAILABLEtEX_USAGE(tterm(ttext(t maybe_iso8601(tCommandtOptiont Extensions(tamqp(tbeat(tevents(tgraph(tworkeru CeleryCommandumainu ---- -- - - ---- Commands- -------------- --- ------------ {commands} ---- -- - - --------- -- - -------------- --- ------------ Type '{prog_name} --help' for help using a specific command. uGMigrating task {state.count}/{state.strtotal}: {body[task]}[{body[id]}]uC_DEBUGuMainuworkerueventsubeatushellumultiuamqpugreenuRemote ControlustatusuinspectucontrolublueuUtilsupurgeulistumigrateucalluresultureportuDebugugraphuredcC@s$t|tjr|S|r tStS(N(t isinstancetnumberstIntegralRR(tret((s3/tmp/pip-unpacked-wheel-gV1wwp/celery/bin/celery.pytdetermine_exit_status@scC@svy^tdkr&tjttjdu--argsu-athelpupositional arguments (json).u--kwargsu-kukeyword arguments (json).u--etauscheduled time (ISO-8601).u --countdownttypeufloatu$eta in seconds from now (float/int).u --expiresu!expiry time (ISO-8601/float/int).u --serializertdefaultujsonudefaults to json.u--queueucustom queue name.u --exchangeucustom exchange name.u --routing-keyucustom routing key.cO@sp|jdpd}t|tr6tj|}n|jdpHi}t|trltj|}n|jdp~d}yt|}WnDttfk ryt |}Wqttfk rqXnX|j j |d|d|d|jdd|jd d |jd d |jd d|jddt |jdd| }|j |j dS(NuargsukwargsuexpiresRQtkwargst countdownu countdownt serializeru serializertqueueuqueuetexchangeuexchanget routing_keyu routing_keytetauetatexpires((tgetRRtanyjsontloadsR4tfloatt TypeErrort ValueErrorR REt send_taskR6tid(R'tnameRKRLRQRVR]tres((s3/tmp/pip-unpacked-wheel-gV1wwp/celery/bin/celery.pyRPs.  (RR0R1RQR t option_listRRP(((s3/tmp/pip-unpacked-wheel-gV1wwp/celery/bin/celery.pyRRstpurgecB@sWeZdZdZdZdZdZeje ddddd d fZe d Z RS( uoErase all messages from all known task queues. WARNING: There is no undo operation for this command. u{warning}: This will remove all tasks from {queues}: {names}. There is no undo for this operation! (to skip this prompt use the -f option) u)Are you sure you want to delete all tasksu9Purged {mnum} {messages} from {qnum} known task {queues}.u'No messages purged from {qnum} {queues}u--forceu-ftactionu store_trueRSuDo not prompt for verificationc K@stt|jjjj}t|}|s|j|jj d|j j ddt j |dddj||j|jd ddkrdSn|jjj}|r|jn|j}|j|j d |d |d t j |d dt j |ddS(NtwarninguWARNINGtqueuesuqueuetnamesu, uyesunotmnumtqnumtmessagesumessage(uyesuno(tlisttsortedRERRltkeystlenR6t warn_preludeR7tcoloredtredR t pluralizeRCtaskt warn_prompttcontrolRit fmt_purgedt fmt_empty(R'tforceRVRmRoRpR;((s3/tmp/pip-unpacked-wheel-gV1wwp/celery/bin/celery.pyRPs! % ( RR0R1RuRzR|R}R RhRR2RP(((s3/tmp/pip-unpacked-wheel-gV1wwp/celery/bin/celery.pyRis tresultcB@sQeZdZdZejeddddeddddd fZd ZRS( u Gives the return value for a given task id. Examples:: celery result 8f511516-e2f5-4da4-9d2f-0fb83a86e500 celery result 8f511516-e2f5-4da4-9d2f-0fb83a86e500 -t tasks.add celery result 8f511516-e2f5-4da4-9d2f-0fb83a86e500 --traceback u u--tasku-tRSu name of task (if custom backend)u --tracebackRju store_trueushow traceback insteadc O@s|jj}|jd}|jdt}|rI|jj|j}n||}|rg|j}n |j}|j|j|ddS(Nutasku tracebacki(REt AsyncResultR^R2ttaskst tracebackR6tpretty( R'ttask_idRQRVt result_clsttaskRRtvalue((s3/tmp/pip-unpacked-wheel-gV1wwp/celery/bin/celery.pyRPs    (RR0R1RQR RhRRP(((s3/tmp/pip-unpacked-wheel-gV1wwp/celery/bin/celery.pyRs  t_RemoteControlcB@seZdZdZeZeje dddddde ddddfZd Z e d d ded Z e d d ded Z edZdZdZdZdZRS(u --timeoutu-tRTufloatRSu,Timeout in seconds (float) waiting for replyu --destinationu-du/Comma separated list of destination node names.cO@sG|jdt|_|jdt|_tt|j||dS(Nu show_bodyu show_reply(tpoptTruet show_bodyt show_replytsuperRt__init__(R'RQRV((s3/tmp/pip-unpacked-wheel-gV1wwp/celery/bin/celery.pyRsiucC@s|r.dtj|j|d|d}nd}yNt||}tjdtjdj||||j||gSWnAtk rtjdtj|t ||||gSXdS(Nu|iiu {0}{1} {2}( R tindenttchoicesR4tgetattrRCR7R1tAttributeErrortstr(R'R.RtprefixtcolorRStmeth((s3/tmp/pip-unpacked-wheel-gV1wwp/celery/bin/celery.pytget_command_infos( c@s]r ndr%dnddjfdtjDS(NcS@s|S(N((tx((s3/tmp/pip-unpacked-wheel-gV1wwp/celery/bin/celery.pyt.tu uu c3@s*|] }j|VqdS(N(R(t.0tc(RRSRRR'(s3/tmp/pip-unpacked-wheel-gV1wwp/celery/bin/celery.pys 0s(RCRrR(R'RRRRS((RRSRRR's3/tmp/pip-unpacked-wheel-gV1wwp/celery/bin/celery.pyt list_commands,scC@s%djd|jdddtgS(Nu u [Commands]RiRS(RCRR(R'((s3/tmp/pip-unpacked-wheel-gV1wwp/celery/bin/celery.pytepilog3scC@sdj||jS(Nu0%prog {0} [options] {1} [arg1 .. argN](R7RQ(R'R.((s3/tmp/pip-unpacked-wheel-gV1wwp/celery/bin/celery.pytusage:scO@stddS(Nucall(R=(R'RQRV((s3/tmp/pip-unpacked-wheel-gV1wwp/celery/bin/celery.pyRR>scO@s1|s!|jdj|n|j||S(Nu#Missing {0.name} method. See --help(RDR7tdo_call_method(R'RQRV((s3/tmp/pip-unpacked-wheel-gV1wwp/celery/bin/celery.pyRPAsc K@sY|d}|dkr1|jdj|n||jkr^|jdj||n|jjjjdkr|jdn|jd}|jdp|j|d}|rt |t rg|j d D]}|j ^q}nt |||j}||d |d |d |j|d }|sU|jddtn|S(NiuhelpuDid you mean '{0.name} --help'?uUnknown {0.name} method {1}usqlu/Broadcast not supported by SQL broker transportu destinationutimeoutu,ttimeoutt destinationtcallbackiu(No nodes replied within time constraint.tstatus(R>R7RRDRERFt transportt driver_typeR^RRtsplittstripRRRtsay_remote_command_replyR( R'RQRVtmethodRRtdestthandlertreplies((s3/tmp/pip-unpacked-wheel-gV1wwp/celery/bin/celery.pyRGs(   +  N(RR0R4RfRR2tleafR RhRRt classmethodRRtpropertyRRRRRPR(((s3/tmp/pip-unpacked-wheel-gV1wwp/celery/bin/celery.pyRs$      tinspectcB@seZdZdZid%d6d&d6d'd6d(d 6d)d 6d*d6d+d6d,d6d-d6d.d6d/d6d0d6d1d6d2d 6Zd!Zd"d#Zed$ZRS(3uInspect the worker at runtime. Availability: RabbitMQ (amqp), Redis, and MongoDB transports. Examples:: celery inspect active --timeout=5 celery inspect scheduled -d worker1@example.com celery inspect revoked -d w1@e.com,w2@e.com uinspectg?u#dump active tasks (being processed)uactiveudump queues being consumed fromu active_queuesu*dump scheduled tasks (eta/countdown/retry)u scheduledu-dump reserved tasks (waiting to be processed)ureservedudump worker statisticsustatsudump of revoked task idsurevokedudump of registered tasksu registeredg?uping worker(s)upinguget value of logical clockuclockudump worker configurationuconfuget bugreport infoureportusample memory (requires psutil)u memsampleu%dump memory samples (requires psutil)umemdumpgN@u'create object graph (requires objgraph)uobjgraphcO@s(|jjj|}t|||S(N(RER{RR(R'RRQtoptionsti((s3/tmp/pip-unpacked-wheel-gV1wwp/celery/bin/celery.pyRRsuRequestcO@s|jd||S(Nuobjgraph(RR(R'ttype_RQRV((s3/tmp/pip-unpacked-wheel-gV1wwp/celery/bin/celery.pytobjgraphscO@s|jd||S(Nuconf(RR(R't with_defaultsRQRV((s3/tmp/pip-unpacked-wheel-gV1wwp/celery/bin/celery.pytconfs(g?u#dump active tasks (being processed)(g?udump queues being consumed from(g?u*dump scheduled tasks (eta/countdown/retry)(g?u-dump reserved tasks (waiting to be processed)(g?udump worker statistics(g?udump of revoked task ids(g?udump of registered tasks(g?uping worker(s)(g?uget value of logical clock(g?udump worker configuration(g?uget bugreport info(g?usample memory (requires psutil)(g?u%dump memory samples (requires psutil)(gN@u'create object graph (requires objgraph)( RR0R1RfRRRRR2R(((s3/tmp/pip-unpacked-wheel-gV1wwp/celery/bin/celery.pyRbs(    R{cB@seZdZdZi dd6d d6d!d6d"d 6d#d 6d$d6d%d6d&d6d'd6ZdZddZddZd(d(dZ dZ d(dZ d(dd(dZ dZ RS()uWorkers remote control. Availability: RabbitMQ (amqp), Redis, and MongoDB transports. Examples:: celery control enable_events --timeout=5 celery control -d worker1@example.com enable_events celery control -d w1.e.com,w2.e.com enable_events celery control -d w1.e.com add_consumer queue_name celery control -d w1.e.com cancel_consumer queue_name celery control -d w1.e.com add_consumer queue exchange direct rkey ucontrolg?utell worker(s) to enable eventsu enable_eventsu tell worker(s) to disable eventsudisable_eventsu)tell worker(s) to start consuming a queueu add_consumeru(tell worker(s) to stop consuming a queueucancel_consumeru7tell worker(s) to modify the rate limit for a task typeu rate_limitu8tell worker(s) to modify the time limit for a task type.u time_limituchange autoscale settingsu autoscaleustart more pool processesu pool_growuuse less pool processesu pool_shrinkcO@s"t|jj|dt||S(Ntreply(RRER{R(R'RRQR((s3/tmp/pip-unpacked-wheel-gV1wwp/celery/bin/celery.pyRRsicK@s|j|t||S(u[N=1](RRtint(R'RtnRV((s3/tmp/pip-unpacked-wheel-gV1wwp/celery/bin/celery.pyt pool_growscK@s|j|t||S(u[N=1](RRR(R'RRRV((s3/tmp/pip-unpacked-wheel-gV1wwp/celery/bin/celery.pyt pool_shrinkscK@s"|j|t|t||S(u [max] [min](RRR(R'RtmaxtminRV((s3/tmp/pip-unpacked-wheel-gV1wwp/celery/bin/celery.pyt autoscalescK@s|j||||S(u0 (e.g. 5/s | 5/m | 5/h)>(RR(R'Rt task_namet rate_limitRV((s3/tmp/pip-unpacked-wheel-gV1wwp/celery/bin/celery.pyRscK@s%|j||t|t||S(u# [hard_secs](RRRa(R'RRtsoftthardRV((s3/tmp/pip-unpacked-wheel-gV1wwp/celery/bin/celery.pyt time_limits udirectcK@s|j||||||S(u' [exchange [type [routing_key]]](RR(R'RRYRZt exchange_typeR[RV((s3/tmp/pip-unpacked-wheel-gV1wwp/celery/bin/celery.pyt add_consumerscK@s|j|||S(u(RR(R'RRYRV((s3/tmp/pip-unpacked-wheel-gV1wwp/celery/bin/celery.pytcancel_consumers(g?utell worker(s) to enable events(g?u tell worker(s) to disable events(g?u)tell worker(s) to start consuming a queue(g?u(tell worker(s) to stop consuming a queue(g?u7tell worker(s) to modify the rate limit for a task type(g?u8tell worker(s) to modify the time limit for a task type.(g?uchange autoscale settings(g?ustart more pool processes(g?uuse less pool processesN(RR0R1RfRRRRRR4RRRRR(((s3/tmp/pip-unpacked-wheel-gV1wwp/celery/bin/celery.pyR{s*      RcB@s eZdZejZdZRS(u%Show list of workers that are online.cO@std|jd|jdtd|jd|jdtdtdt}|jd |}|sx|jd d t nt |}|jd ts|j d j |t j|dndS(NRER+uno_colortstdouttstderrRRR*upingu'No nodes replied within time constraintRuquietu {0} {1} online.unode(RRER^R2RRRRPR>RRtR6R7R Rx(R'RQRVtIRt nodecount((s3/tmp/pip-unpacked-wheel-gV1wwp/celery/bin/celery.pyRPs     (RR0R1RRhRP(((s3/tmp/pip-unpacked-wheel-gV1wwp/celery/bin/celery.pyRs tmigratec B@seZdZdZejeddddddedd dd d d dd eddddddeddddeddddeddddddfZeZdZ dZ RS(u%Migrate tasks from one broker to another. Examples:: celery migrate redis://localhost amqp://guest@localhost// celery migrate django:// redis://localhost NOTE: This command is experimental, make sure you have a backup of the tasks before you continue. u u--limitu-nRTuintRSu Number of tasks to consume (int)u --timeoutu-tufloatRUg?u,Timeout in seconds (float) waiting for tasksu--ack-messagesu-aRju store_trueu Ack messages from source broker.u--tasksu-Tu List of task names to filter on.u--queuesu-QuList of queues to migrate.u --foreveru-Fu'Continually migrate tasks until killed.cC@s&|j|jjd|d|dS(Ntstatetbody(R6t progress_fmtR7(R'RRtmessage((s3/tmp/pip-unpacked-wheel-gV1wwp/celery/bin/celery.pyton_migrate_taskscK@sIddlm}ddlm}|||||d|j|dS(Ni(t Connection(t migrate_tasksR(tkombuRtcelery.contrib.migrateRR(R'tsourceRRVRR((s3/tmp/pip-unpacked-wheel-gV1wwp/celery/bin/celery.pyRPs   ( RR0R1RQR RhRtMIGRATE_PROGRESS_FMTRRRP(((s3/tmp/pip-unpacked-wheel-gV1wwp/celery/bin/celery.pyRs$     tshellc B@s#eZdZejedddddddded d dddd dd ed dddddddeddddddedddddedddddfZeeeeeedZdZdZ dZ dZ dZ dZ dZd Zd!ZRS("uStart shell session with convenient access to celery symbols. The following symbols will be added to the main globals: - celery: the current application. - chord, group, chain, chunks, xmap, xstarmap subtask, Task - all registered tasks. u --ipythonu-IRju store_trueRu force_ipythonRSuforce iPython.u --bpythonu-Bu force_bpythonuforce bpython.u--pythonu-Pu force_pythonuforce default Python shell.u--without-tasksu-Tudon't add tasks to locals.u --eventletu use eventlet.u--geventu use gevent.c K@sMtjjdtj|r,tdn|r?tdnddl}ddl}|jj j i |jd6|jd6|j d6|j d6|j d6|jd 6|jd 6|jd 6|jd 6|jd 6|jd6|_|s|jjtdt|jjDn|r#|jS|r3|jS|rC|jS|jS(Niucelery.concurrency.eventletucelery.concurrency.geventuappuceleryuTaskuchordugroupuchainuchunksuxmapuxstarmapusubtasku signaturecs@s0|]&}|jjds|j|fVqdS(ucelery.N(Rft startswithR(RR((s3/tmp/pip-unpacked-wheel-gV1wwp/celery/bin/celery.pys As(RtpathtinserttostgetcwdRtcelerytcelery.task.baseREtloadertimport_default_modulestTasktchordtgrouptchaintchunkstxmaptxstarmaptsubtaskt signaturetlocalstupdatetdictRRtinvoke_fallback_shelltinvoke_bpython_shelltinvoke_ipython_shelltinvoke_default_shell( R't force_ipythont force_bpythont force_pythont without_tasksteventlettgeventRVR((s3/tmp/pip-unpacked-wheel-gV1wwp/celery/bin/celery.pyRP(s:               #   cC@sgyddl}WnFtk rXyddl}Wntk rJ|jSX|jSn X|jSdS(Ni(tIPythont ImportErrortbpythonRRR(R'RR((s3/tmp/pip-unpacked-wheel-gV1wwp/celery/bin/celery.pyRMs   cC@s|ddl}yddl}Wntk r/n6Xddl}|j|j|jj|jd|j d|jdS(Niu tab:completetlocal( tcodetreadlineRt rlcompletert set_completert CompleterRtcompletetparse_and_bindtinteract(R'RRR((s3/tmp/pip-unpacked-wheel-gV1wwp/celery/bin/celery.pyRZs    cC@sRxK|j|j|j|j|jfD]%}y |SWq%tk rIq%Xq%WdS(N(t_ipythont_ipython_pre_10t_ipython_terminalt _ipython_010t _no_ipythonR(R'tip((s3/tmp/pip-unpacked-wheel-gV1wwp/celery/bin/celery.pyRgs   cC@s*ddlm}|dgd|jdS(Ni(t start_ipythonR#tuser_ns(RR R(R'R ((s3/tmp/pip-unpacked-wheel-gV1wwp/celery/bin/celery.pyRpscC@sPddlm}|j}|jdg|jjj|j|jdS(Ni(tTerminalIPythonAppR#( tIPython.frontend.terminal.ipappR tinstancet initializeRR RRtstart(R'R RE((s3/tmp/pip-unpacked-wheel-gV1wwp/celery/bin/celery.pyRts  cC@s-ddlm}|jd|jjdS(Ni(tembedR (tIPython.terminalRtTerminalInteractiveShellRtmainloop(R'R((s3/tmp/pip-unpacked-wheel-gV1wwp/celery/bin/celery.pyR{scC@s0ddlm}|dgd|jjdS(Ni(tIPShellR#R (t IPython.ShellRRR(R'R((s3/tmp/pip-unpacked-wheel-gV1wwp/celery/bin/celery.pyRscC@stddS(Nuno suitable ipython found(R(R'((s3/tmp/pip-unpacked-wheel-gV1wwp/celery/bin/celery.pyRscC@s ddl}|j|jdS(Ni(RRR(R'R((s3/tmp/pip-unpacked-wheel-gV1wwp/celery/bin/celery.pyRs (RR0R1R RhRR2RPRRRRRRRRR(((s3/tmp/pip-unpacked-wheel-gV1wwp/celery/bin/celery.pyR s8         #     RScB@s eZdZdZdZRS(uShow help screen and exit.cC@s dj|S(Nu"%prog [options] {0.args}(R7(R'R.((s3/tmp/pip-unpacked-wheel-gV1wwp/celery/bin/celery.pyRscO@sB|jj|jtjd|jdtjd|jt S(NR-tcommandsRv( tparsert print_helpR6tHELPR7R-RRRvR (R'RQRV((s3/tmp/pip-unpacked-wheel-gV1wwp/celery/bin/celery.pyRPs   (RR0R1RRP(((s3/tmp/pip-unpacked-wheel-gV1wwp/celery/bin/celery.pyRSs treportcB@seZdZdZRS(u2Shows information useful to include in bugreports.cO@s|j|jjtS(N(R6REt bugreportR(R'RQRV((s3/tmp/pip-unpacked-wheel-gV1wwp/celery/bin/celery.pyRPs(RR0R1RP(((s3/tmp/pip-unpacked-wheel-gV1wwp/celery/bin/celery.pyRsRcB@s9eZdZdZied6ed6ed6ed6ed6e d6e d6e d 6e d 6e d 6ed 6ed 6ed6ed6ed6ed6ed6ZeZdZed dZd dZd dZddZdZdZ d dZ!edd d dZ"edd dZ#dZ$dZ%dZ&RS(!uceleryu{self.namespace}.commandsuamqpubeatucallucontrolueventsugraphuhelpuinspectulistumigrateumultiupurgeureporturesultushellustatusuworkercC@s||j|p|j<|S(N(RR(tclstfunRf((s3/tmp/pip-unpacked-wheel-gV1wwp/celery/bin/celery.pytregister_commandscC@sy|j|}Wn(tk r;|jddg}}nX|jj|pX|jd}ya|d|jd|jd|jd|jdt|jd|j |j |dd|d SWnM|j k r}|j||j S|j k r }|j||j SXdS( NuhelpREton_errorR+R*ton_usage_errorR.ii(RtKeyErrorR^RER R+R*RR!R/R-RDRR>(R'R.R#Rtexc((s3/tmp/pip-unpacked-wheel-gV1wwp/celery/bin/celery.pytexecutes"   cC@sc|rd}nd}|j|jjdj||jdj|jd|d|dS(Nu!{self.prog_name} {command} --helpu{self.prog_name} --helpu Error: {0}uPlease try '{0}'R'R.(terrorRvtmagentaR7(R'R#R.thelps((s3/tmp/pip-unpacked-wheel-gV1wwp/celery/bin/celery.pyR!s  "icC@s |rg}x|t|kr||}|jdrJ|j|n|jdryN||d}|jdr|j|n|j||g|d7}Wqtk r|j|PqXnP|d7}qW||r|||S|jg|ngS(Nu--u-i(RtRtappendtextendt IndexErrorR(R'R#tindextrestRtnxt((s3/tmp/pip-unpacked-wheel-gV1wwp/celery/bin/celery.pyt_relocate_args_from_starts,     cC@s|dkrtjdjS|S(Nu __main__.pyu__main__(RRt__file__(R'Rf((s3/tmp/pip-unpacked-wheel-gV1wwp/celery/bin/celery.pytprepare_prog_names cC@s{|j||_|j|}|jd|\}}y|d}Wn!tk rjddg}}nX|j||S(Niuhelp(R0R-R.t prepare_argsR4R*R$(R'R-R#RKR.((s3/tmp/pip-unpacked-wheel-gV1wwp/celery/bin/celery.pyt handle_argv s cC@s|dkrtjn|}d|dd!kr:t|_ny)tjttt|j |Wnt k rtjt nXdS(Numultiii( R4RR#R2R3texitRRRR!R"R(R'R#((s3/tmp/pip-unpacked-wheel-gV1wwp/celery/bin/celery.pyR!s    cC@s|dkrtjn|}|r1|j|nd}|j|}dj||}|jrydtj||Stj ddtjdj|||j |dj||gS(NcS@s|S(N((R((s3/tmp/pip-unpacked-wheel-gV1wwp/celery/bin/celery.pyR Ru celery {0}u|u u {0} --help( R4R RvRmRR7RR RRCR(R'R.RRRvtobjR$((s3/tmp/pip-unpacked-wheel-gV1wwp/celery/bin/celery.pyRs  c@sdkrtjnj}g}xjtD]b\}}|jtjdj||dj fd|Ddgq4Wdj |j S(Nu+ {0}: u c3@s+|]!}j|dVqdS(iN(R(RR.(RRvRR'(s3/tmp/pip-unpacked-wheel-gV1wwp/celery/bin/celery.pys 4su( R4R Rvtwhitetcommand_classesR)R RR7RCR(R'RRvR5RRR((RRvRR's3/tmp/pip-unpacked-wheel-gV1wwp/celery/bin/celery.pyR+s  cC@s9t|dkr5d|dd!kr5dgdgfSdS(Niuworkeriiu-Pu--pool(Rt(R'R#((s3/tmp/pip-unpacked-wheel-gV1wwp/celery/bin/celery.pytwith_pool_option:s%cC@s|jdS(N(tload_extension_commands(R'((s3/tmp/pip-unpacked-wheel-gV1wwp/celery/bin/celery.pyton_concurrency_setup@scC@sJt|jjd||jj}|rFtjd|dfndS(NR'u Extensionsumagenta(Rtext_fmtR7RtloadR6R((R'Rm((s3/tmp/pip-unpacked-wheel-gV1wwp/celery/bin/celery.pyR8CsN('RR0t namespaceR:RRRRR{RRRSRR5RR&RiRRRRRRRtenable_config_from_cmdlineR-RR4RR$R!R.R0R2R!RRR7R9R8(((s3/tmp/pip-unpacked-wheel-gV1wwp/celery/bin/celery.pyRsJ   %     cO@s!tj}|r||dS|S(uODeprecated: Use classmethod :meth:`CeleryCommand.register_command` instead.i(RR(RQRVt _register((s3/tmp/pip-unpacked-wheel-gV1wwp/celery/bin/celery.pyR.Js u__main__(CR1t __future__RRR_RRRt functoolsRt importlibRt celery.fiveRRtcelery.platformsRRRR t celery.utilsR R tcelery.utils.timeutilsR tcelery.bin.baseR RRtcelery.bin.amqpRtcelery.bin.beatRtcelery.bin.eventsRtcelery.bin.graphRtcelery.bin.workerRt__all__RRtenvironR^R2tDEBUGR4R6R(RR%R&R5RRRiRRRR{RRRRSRRR.R(((s3/tmp/pip-unpacked-wheel-gV1wwp/celery/bin/celery.pyts^    " $  '7% Z)C)