P'^c@@sdZddlmZmZmZddlZddlZddlZddlZddl Z ddl Z ddl m Z ddl mZddlmZddlmZmZmZddlmZdd lmZmZmZdd lmZdd lmZmZdd l m!Z!m"Z"m#Z#dd l$m%Z%m&Z&m'Z'ddl(m)Z)ddl(m*Z*ddl(m+Z+m,Z,ddl-m.Z.m/Z/y e0Z1Wne2k rnXx'eefD]Z3e j4de3dqWdZ5ej6dZ7ej6dZ8dddddddgZ9de:fdYZ;de;fd YZ<d!e=fd"YZ>d#efd$YZ?d%e=fd&YZ@eAeAd'ZBdS((u .. _preload-options: Preload Options --------------- These options are supported by all commands, and usually parsed before command-specific arguments. .. cmdoption:: -A, --app app instance to use (e.g. module.attr_name) .. cmdoption:: -b, --broker url to broker. default is 'amqp://guest@localhost//' .. cmdoption:: --loader name of custom loader class to use. .. cmdoption:: --config Name of the configuration module .. _daemon-options: Daemon Options -------------- These options are supported by commands that can detach into the background (daemon). They will be present in any command that also has a `--detach` option. .. cmdoption:: -f, --logfile Path to log file. If no logfile is specified, `stderr` is used. .. cmdoption:: --pidfile Optional file used to store the process pid. The program will not start if this file already exists and the pid is still alive. .. cmdoption:: --uid User id, or user name of the user to run as after detaching. .. cmdoption:: --gid Group id, or group name of the main group to change to after detaching. .. cmdoption:: --umask Effective umask (in octal) of the process after detaching. Inherits the umask of the parent process by default. .. cmdoption:: --workdir Optional directory to change to after detaching. .. cmdoption:: --executable Executable to use for the detached process. i(tabsolute_importtprint_functiontunicode_literalsN(t defaultdict(theappush(t getargspec(t OptionParsertIndentedHelpFormattert make_option(tpformat(tVERSION_BANNERtCelerytmaybe_patch_concurrency(tsignals(tCDeprecationWarningtCPendingDeprecationWarning(titemststringtstring_t(t EX_FAILUREtEX_OKtEX_USAGE(tterm(ttext(t node_formatt host_format(tsymbol_by_nametimport_from_cwduonceu7 Unrecognized command-line arguments: {0} Try --help? u.+?(--.+?)(?:\s|,|$)u :\w+:`(.+?)`uErroru UsageErroru Extensionsu HelpFormatteruCommanduOptionudaemon_optionstErrorcB@s)eZeZddZdZeZRS(cC@sD||_|dk r|n|j|_tt|j||dS(N(treasontNonetstatustsuperRt__init__(tselfRR((s1/tmp/pip-unpacked-wheel-gV1wwp/celery/bin/base.pyR!ys cC@s|jS(N(R(R"((s1/tmp/pip-unpacked-wheel-gV1wwp/celery/bin/base.pyt__str__~sN(t__name__t __module__RRRR!R#t __unicode__(((s1/tmp/pip-unpacked-wheel-gV1wwp/celery/bin/base.pyRvs  t UsageErrorcB@seZeZRS((R$R%RR(((s1/tmp/pip-unpacked-wheel-gV1wwp/celery/bin/base.pyR'st ExtensionscB@s#eZdZdZdZRS(cC@sg|_||_||_dS(N(tnamest namespacetregister(R"R*R+((s1/tmp/pip-unpacked-wheel-gV1wwp/celery/bin/base.pyR!s  cC@s't|j||j|d|dS(Ntname(RR)R+(R"tclsR,((s1/tmp/pip-unpacked-wheel-gV1wwp/celery/bin/base.pytaddscC@syddlm}Wntk r(dSXx||jD]}}dj|j|jdg}yt|}Wn2ttfk r}t j dj ||q9X|j ||j q9W|jS(Ni(titer_entry_pointsu:u"Cannot load extension {0!r}: {1!r}(t pkg_resourcesR/t ImportErrorR*tjoint module_nametattrsRt SyntaxErrortwarningstwarntformatR.R,R)(R"R/teptsymR-texc((s1/tmp/pip-unpacked-wheel-gV1wwp/celery/bin/base.pytloads (R$R%R!R.R<(((s1/tmp/pip-unpacked-wheel-gV1wwp/celery/bin/base.pyR(s  t HelpFormattercB@seZdZdZRS(cC@s|rdj|SdS(Nu {0} u(R8(R"tepilog((s1/tmp/pip-unpacked-wheel-gV1wwp/celery/bin/base.pyt format_epilogs cC@s%tjtjtj||jS(N(Rt ensure_2linestfill_paragraphstdedenttwidth(R"t description((s1/tmp/pip-unpacked-wheel-gV1wwp/celery/bin/base.pytformat_descriptions (R$R%R?RE(((s1/tmp/pip-unpacked-wheel-gV1wwp/celery/bin/base.pyR=s tCommandc B@seZdZeZeZeZdZeZ e Z dAZ dBZe ZeddddBeddddBedddBedddBed ddBd d ed d ddddBeddddfZeZdZdBZdZe Ze Ze ZdZdBdBedBdBedBdBdZdZdZdZdZdZ ddZ!dBdZ"dBdBdZ#dBdZ$dZ%dZ&d Z'dBd!Z(dBd"Z)d#Z*d$Z+d%Z,dBd&Z-e.d'Z/d(Z0dBd)Z1dBd*Z2d+Z3d,Z4d-Z5e6d.Z7e7Z8d/Z9d0Z:d1Z;d2Z<d3Z=d4Z>d5Z?d6Z@d7ZAd8ZBd9ZCd:ZDd;ZEdd<ZFeGd=ZHeHjId>ZHeGd?ZJeJjId@ZJRS(CuBase class for command-line applications. :keyword app: The current app. :keyword get_app: Callable returning the current app if no app provided. uu-Au--apptdefaultu-bu--brokeru--loaderu--configu --workdirtdestuworking_directoryu --no-coloru-Ctactionu store_trueu--quietu-quceleryc C@s||_|p|j|_|p'tj|_|p9tj|_d|_||_||_ |j sr|j |_ n|r||_ n|r||_ ndS(N(tappt_get_default_apptget_apptsyststdouttstderrRt_coloredt _no_colortquietRDt__doc__ton_errorton_usage_error( R"RJRLtno_colorRNRORRRTRU((s1/tmp/pip-unpacked-wheel-gV1wwp/celery/bin/base.pyR!s      cO@stddS(u>This is the body of the command called by :meth:`handle_argv`.usubclass responsibilityN(tNotImplementedError(R"targstoptions((s1/tmp/pip-unpacked-wheel-gV1wwp/celery/bin/base.pytrunscC@s&|j|jjdj|dS(Nu Error: {0}(terrortcoloredtredR8(R"R;((s1/tmp/pip-unpacked-wheel-gV1wwp/celery/bin/base.pyRTscC@s|j|dS(N(t handle_error(R"R;((s1/tmp/pip-unpacked-wheel-gV1wwp/celery/bin/base.pyRUscC@sdS(N((R"((s1/tmp/pip-unpacked-wheel-gV1wwp/celery/bin/base.pyton_concurrency_setup scO@stj|j|y*|j||}|dk r<|StSWnM|jk rj}|j||jS|j k r}|j ||jSXdS(N( trandomtseedt verify_argsRZRRR'RURRRT(R"RXtkwargstretR;((s1/tmp/pip-unpacked-wheel-gV1wwp/celery/bin/base.pyt__call__s    icC@st|j}|jr1|jddkr1dn|}|j||jrYt|j nd!}|t|}|r|jdjtj t|ddj |ndS(NiuselfiuMissing required {0}: {1}uargumentu, ( RRZRXtdefaultstlenRR'R8Rt pluralizeR2(R"tgivent_indextStrequiredtmissing((s1/tmp/pip-unpacked-wheel-gV1wwp/celery/bin/base.pyRbs() cC@s|dkrttj}n|j||j|j||j|}tj j |d|_ |j |j |dS(uExecute application from command-line. :keyword argv: The list of command-line arguments. Defaults to ``sys.argv``. iiN( RtlistRMtargvR R_t early_versiontsetup_app_from_commandlinetostpathtbasenamet prog_namet handle_argv(R"Ro((s1/tmp/pip-unpacked-wheel-gV1wwp/celery/bin/base.pytexecute_from_commandline&s    cC@s(|j||dkrtjn||S(N(RvRRMRo(R"RuRotcommand((s1/tmp/pip-unpacked-wheel-gV1wwp/celery/bin/base.pyt run_from_argv9s cC@sD|p tj}|j|}|r@t|||\}}ndS(N(RMRotwith_pool_optionR (R"Rot pool_optiont short_optst long_opts((s1/tmp/pip-unpacked-wheel-gV1wwp/celery/bin/base.pyR =s  cC@sdj|d|S(Nu%prog {0} [options] {self.args}R"(R8(R"Rx((s1/tmp/pip-unpacked-wheel-gV1wwp/celery/bin/base.pytusageDscC@s|jS(u#Get supported command-line options.(t option_list(R"((s1/tmp/pip-unpacked-wheel-gV1wwp/celery/bin/base.pyt get_optionsGscC@s#t|trtjj|S|S(N(t isinstanceRRrRst expanduser(R"tvalue((s1/tmp/pip-unpacked-wheel-gV1wwp/celery/bin/base.pyRKscC@s|}|dk rLg|D]*}||kr7|jn |j^q}ndj|}dj|j|}x6t|j}||kr|S|dk rvPqvqvW|S(uPrompt user to choose from a tuple of string values. :param q: the question to ask (do not include questionark) :param choice: tuple of possible choices, must be lowercase. :param default: Default value if any. If a default is not specified the question will be repeated until the user gives a valid choice. Matching is done case insensitively. u/u {0} ({1})? N(RtuppertlowerR2R8t capitalizetinput(R"tqtchoicesRGtschoicestctptval((s1/tmp/pip-unpacked-wheel-gV1wwp/celery/bin/base.pytaskPs  7  cC@s1|j|j|||\}}|||S(u:Parse command-line arguments from ``argv`` and dispatch to :meth:`run`. :param prog_name: The program name (``argv[0]``). :param argv: Command arguments. Exits with an error message if :attr:`supports_args` is disabled and ``argv`` contains positional arguments. (t prepare_argst parse_options(R"RuRoRxRYRX((s1/tmp/pip-unpacked-wheel-gV1wwp/celery/bin/base.pyRvls c@sj|r1tfdtt|D}ng|D]}j|^q8}j|||fS(Nc3@s9|]/\}}|jds|j|fVqdS(u_N(t startswithR(t.0tktv(R"(s1/tmp/pip-unpacked-wheel-gV1wwp/celery/bin/base.pys }s (tdictRtvarsRt check_args(R"RYRXtarg((R"s1/tmp/pip-unpacked-wheel-gV1wwp/celery/bin/base.pyR{s " cC@s9|j r5|r5|jtjdj|tndS(Nu, (t supports_argstdiet ARGV_DISABLEDR8R2R(R"RX((s1/tmp/pip-unpacked-wheel-gV1wwp/celery/bin/base.pyRscC@s|j|d|jdS(Ntfh(toutRO(R"ts((s1/tmp/pip-unpacked-wheel-gV1wwp/celery/bin/base.pyR[scC@st|d|p|jdS(Ntfile(tprintRN(R"RR((s1/tmp/pip-unpacked-wheel-gV1wwp/celery/bin/base.pyRscC@s|j|tj|dS(N(R[RMtexit(R"tmsgR((s1/tmp/pip-unpacked-wheel-gV1wwp/celery/bin/base.pyRs cC@s6d|kr2t|jd|jtjdndS(Nu --versionRi(RtversionRNRMR(R"Ro((s1/tmp/pip-unpacked-wheel-gV1wwp/celery/bin/base.pyRps cC@s%|j|||_|jj|S(uParse the available options.(t create_parsertparsert parse_args(R"Rut argumentsRx((s1/tmp/pip-unpacked-wheel-gV1wwp/celery/bin/base.pyRscC@sy|j|jt|jjd}|j|jd|d|j|d|jd|j dt d|j d|S( NupreloadtprogR~RR>t formatterRDR( tpreload_optionsRttupleRJt user_optionstprepare_parsertParserR~RR>R=RD(R"RuRxR((s1/tmp/pip-unpacked-wheel-gV1wwp/celery/bin/base.pyRs    cC@sg|jtfD]}|r|j|^q}xj|D]b}xYt|D]K\}}|j|}|dk rKdj|jd|j|_ qKqKWq8W|S(Nu RG( tdocRSt parse_docRt get_optionRR2R8RGthelp(R"RRtdocstlong_optRtoption((s1/tmp/pip-unpacked-wheel-gV1wwp/celery/bin/base.pyRs1  ,c C@s9|j|}|jd}|dk r6||_ny|d|_Wntk rZnX|jd}|rtj|n|jdptjjdp|j }|jd}|r|tjdTs(R\R2(R"tn((Rs1/tmp/pip-unpacked-wheel-gV1wwp/celery/bin/base.pyt pretty_listOs  cC@s|j}y4|jdtj|j|dddfSWntk rPnX|jdtj|j|dddfS(NuOKuokiiuERRORuerror(R\tgreenRtindenttprettyRR](R"RR((s1/tmp/pip-unpacked-wheel-gV1wwp/celery/bin/base.pytpretty_dict_ok_errorWs  (  cC@s||j}tt|}||}|j|\}}|jd|j|d||jrqtj|dnddS(Nu->u: iu( R\tnexttiterRtsay_chattcyant show_replyRR(R"trepliesRtnodetreplyRtpreply((s1/tmp/pip-unpacked-wheel-gV1wwp/celery/bin/base.pytsay_remote_command_replyas   cC@st|jjd}t|tr:||j|fSt|trd|ksad|krn|j|S|tj |dt ddfSnt|t r|t |fS|t |fS(NuOKuokuerrort sort_keysRi(RR\RRRnRRRtjsontdumpsRRRR (R"RtOK((s1/tmp/pip-unpacked-wheel-gV1wwp/celery/bin/base.pyRis "cC@s|j}|dkr"|jr"dS|j rG|j|j|dpJd}|j|j|||r|jr|j|ndS(Nu<-u u(R\RRtboldRRRt show_body(R"t directionttitletbodyRtdirstr((s1/tmp/pip-unpacked-wheel-gV1wwp/celery/bin/base.pyRvs +cC@s2|jdkr+tjd|j |_n|jS(Ntenabled(RPRRR\RV(R"((s1/tmp/pip-unpacked-wheel-gV1wwp/celery/bin/base.pyR\scC@s ||_dS(N(RP(R"tobj((s1/tmp/pip-unpacked-wheel-gV1wwp/celery/bin/base.pyR\scC@s|jS(N(RQ(R"((s1/tmp/pip-unpacked-wheel-gV1wwp/celery/bin/base.pyRVscC@s/||_|jdk r+|j |j_ndS(N(RQRPRR(R"R((s1/tmp/pip-unpacked-wheel-gV1wwp/celery/bin/base.pyRVs (N(KR$R%RSRR'RRRXR RRRRRRRtOptionRtFalseRR*R>RDtleafR RRuR!RZRTRUR_ReRbRwRyR R~RRRRvRRR[RRRRpRRRRqRRRtget_cls_by_nameRRRRRRzRRRKRRRRRtpropertyR\tsetterRV(((s1/tmp/pip-unpacked-wheel-gV1wwp/celery/bin/base.pyRFs                      0     /      c C@satddd|tdd|tdddtdddtdddtdddfS( Nu-fu --logfileRGu --pidfileu--uidu--gidu--umasku --executable(RR(tdefault_pidfiletdefault_logfile((s1/tmp/pip-unpacked-wheel-gV1wwp/celery/bin/base.pytdaemon_optionss (CRSt __future__RRRRrR`treRMR6Rt collectionsRtheapqRtinspectRtoptparseRRRRtpprintR tceleryR R R R tcelery.exceptionsRRt celery.fiveRRRtcelery.platformsRRRt celery.utilsRRRRtcelery.utils.importsRRt raw_inputRt NameErrortwarningt simplefilterRtcompileRRt__all__t ExceptionRR'tobjectR(R=RFRR(((s1/tmp/pip-unpacked-wheel-gV1wwp/celery/bin/base.pytFsN