o wvXj8@sdZddlmZmZmZddlZddlZddlmZddl m Z ddl m Z m Z ddlmZddlmZdd lmZdd lmZmZmZdd lmZdd lmZdd lmZddlmZddlm Z ddl!m"Z"ddl#m$Z$ddl%m&Z&ddl'm(Z(ddl)m*Z*ddl+m,Z,m-Z-m.Z.ddl/m0Z0m1Z1dZ2dZ3dgddfdgddfdgd dfd!d"d#gd$fgZ4d%d&Z5d1d'd(Z6Gd)d*d*e Z7Gd+d,d,e Z8Gd-d"d"e Z9Gd.d/d/e Z:e;d0kre6dSdS)2aThe :program:`celery` umbrella command. .. program:: celery .. _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 .. cmdoption:: -C, --no-color Disable colors in output. .. cmdoption:: -q, --quiet Give less verbose output (behavior depends on the sub command). .. cmdoption:: --help Show help and exit. .. _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 won't 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. ``celery inspect`` ------------------ .. program:: celery inspect .. cmdoption:: -t, --timeout Timeout in seconds (float) waiting for reply .. cmdoption:: -d, --destination Comma separated list of destination node names. .. cmdoption:: -j, --json Use json as output format. ``celery control`` ------------------ .. program:: celery control .. cmdoption:: -t, --timeout Timeout in seconds (float) waiting for reply .. cmdoption:: -d, --destination Comma separated list of destination node names. .. cmdoption:: -j, --json Use json as output format. ``celery migrate`` ------------------ .. program:: celery migrate .. cmdoption:: -n, --limit Number of tasks to consume (int). .. cmdoption:: -t, -timeout Timeout in seconds (float) waiting for tasks. .. cmdoption:: -a, --ack-messages Ack messages from source broker. .. cmdoption:: -T, --tasks List of task names to filter on. .. cmdoption:: -Q, --queues List of queues to migrate. .. cmdoption:: -F, --forever Continually migrate tasks until killed. ``celery upgrade`` ------------------ .. program:: celery upgrade .. cmdoption:: --django Upgrade a Django project. .. cmdoption:: --compat Maintain backwards compatibility. .. cmdoption:: --no-backup Don't backup original files. ``celery shell`` ---------------- .. program:: celery shell .. cmdoption:: -I, --ipython Force :pypi:`iPython` implementation. .. cmdoption:: -B, --bpython Force :pypi:`bpython` implementation. .. cmdoption:: -P, --python Force default Python shell. .. cmdoption:: -T, --without-tasks Don't add tasks to locals. .. cmdoption:: --eventlet Use :pypi:`eventlet` monkey patches. .. cmdoption:: --gevent Use :pypi:`gevent` monkey patches. ``celery result`` ----------------- .. program:: celery result .. cmdoption:: -t, --task Name of task (if custom backend). .. cmdoption:: --traceback Show traceback if any. ``celery purge`` ---------------- .. program:: celery purge .. cmdoption:: -f, --force Don't prompt for verification before deleting messages (DANGEROUS) ``celery call`` --------------- .. program:: celery call .. cmdoption:: -a, --args Positional arguments (json format). .. cmdoption:: -k, --kwargs Keyword arguments (json format). .. cmdoption:: --eta Scheduled time in ISO-8601 format. .. cmdoption:: --countdown ETA in seconds from now (float/int). .. cmdoption:: --expires Expiry time in float/int seconds, or a ISO-8601 date. .. cmdoption:: --serializer Specify serializer to use (default is json). .. cmdoption:: --queue Destination queue. .. cmdoption:: --exchange Destination exchange (defaults to the queue exchange). .. cmdoption:: --routing-key Destination routing key (defaults to the queue routing key). )absolute_importprint_functionunicode_literalsN)partial)amqp)Command Extensions)beat)call)_RemoteControl)controlinspectstatus)events)graph)list_)logtool)migrate)purge)result)shell)upgrade)worker) EX_FAILUREEX_OKEX_USAGE)termtext) CeleryCommandmainz ---- -- - - ---- Commands- -------------- --- ------------ {commands} ---- -- - - --------- -- - -------------- --- ------------ Type '{prog_name} --help' for help using a specific command. Main)rrr rmultirgreenzRemote Control)rr r blueUtils)rlistr rrrr DebuggingreportrredcCst|tjr|S|r tStSN) isinstancenumbersIntegralrr)retr.N/var/www/html/myproject/venv/lib/python3.10/site-packages/celery/bin/celery.pydetermine_exit_status0s  r0cCs^z$tdkr tjttjd<t}|ddlm}|||WdSty.YdSw)zStart celery umbrella command.__main__r)freeze_supportN) __name__sysmodulesrmaybe_patch_concurrencybilliardr2execute_from_commandlineKeyboardInterrupt)argvcmdr2r.r.r/r6s  rc@seZdZdZdZdddZdS)r!z Start multiple worker instances.FNcCs,ddlm}||j|jd}||g|S)Nr) MultiTool)quietno_color)celery.bin.multir<r=r>r8)self prog_namer:commandr<r;r.r.r/ run_from_argvLs zmulti.run_from_argvr))r3 __module__ __qualname____doc__respects_app_optionrCr.r.r.r/r!Gsr!c@s eZdZdZddZddZdS)helpzShow help screen and exit.cCs d|S)Nz%%(prog)s [options] {0.args})formatr@rBr.r.r/usageUs z help.usagecOs2|j|tj|jtj|j|j ddt S)N)coloredapp)rAcommands) parser print_helpoutHELPrIrAr list_commandsrLrMrr@argskwargsr.r.r/runXs zhelp.runN)r3rDrErFrKrWr.r.r.r/rHRs rHcs(eZdZdZfddZddZZS)r'z3Shows information useful to include in bug-reports.cs&tt|j|i||jjdS)a5Custom initialization for report command. We need this custom initialization to make sure that everything is loaded when running a report. There has been some issues when printing Django's settings because Django is not properly setup when running the report. N)superr'__init__rMloaderimport_default_modulesrT __class__r.r/rYfs zreport.__init__cOs||jtSr))rQrM bugreportrrTr.r.r/rWrsz report.run)r3rDrErFrYrW __classcell__r.r.r\r/r'cs  cseZdZdZidededededede de d e d e d e d ed edededededeeedZdZdZdZdZed1ddZd1ddZd1ddZd2dd Z d!d"Z!d#d$Z"d1fd%d& Z#e  d3d'd(Z$ed4d)d*Z%d+d,Z&d-d.Z'd/d0Z(Z)S)5rzBase class for commands.rr r r rrrHr r%rrr!rr'rrr)rrz{self.namespace}.commandsTceleryNcCs||j|p|j<|Sr))rNr3)clsfunnamer.r.r/register_commandszCeleryCommand.register_commandc Csz|j|}Wnty|jddg}}Ynwz ||j|j|j|jt|j|ddj|j |dd|ddWS|j yU}z|||j WYd}~Sd}~w|j yo}z|||j WYd}~Sd}~ww)NrH)rB)rMon_errorr>r=on_usage_errorr) rNKeyErrorrMrer>r=rrfrCrA UsageErrorrError)r@rBr:raexcr.r.r/executes,    zCeleryCommand.executecCsD|rd}nd}||jd||d|j||ddS)Nz!{self.prog_name} {command} --helpz{self.prog_name} --helpz Error: {0}zPlease try '{0}'rJ)errorrLmagentarI)r@rkrBhelpsr.r.r/rfs zCeleryCommand.on_usage_errorrcCs|rkg}|t|krV||}|dr||n3|drKz||d}|dr0||n |||g|d7}WntyJ||Yn wn |d7}|t|ks ||drd||d|S|g|gS)Nz---rg)len startswithappendextend IndexErrorpop)r@r:indexrestvaluenxtr.r.r/_relocate_args_from_starts2          z'CeleryCommand._relocate_args_from_startcCs|dkr tjdjS|S)Nz __main__.pyr1)r4r5__file__)r@rcr.r.r/prepare_prog_names zCeleryCommand.prepare_prog_namecKs^|||_||}|d|\}}z|d}Wnty(ddg}}Ynw|||S)NrrH)r}rAr{ prepare_argsrurl)r@rAr:rV_rBr.r.r/ handle_argvs     zCeleryCommand.handle_argvcsh|durtjn|}d|ddvrd|_ztttt||WdSty3tt YdSw)Nr!rgF) r4r:rGexitr0rXrr8r9rr@r:r\r.r/r8s z&CeleryCommand.execute_from_commandlinec Cs|durtn|}|r|j|ndd}|j|}d||}|jr,dt||Stddtd|||j |d|||dgS)NcSs|Sr)r.)xr.r.r/sz0CeleryCommand.get_command_info..z celery {0}| z {0} --helprM) rrLnamesrNrIleafrindentjoinrS)rarBrcolorrLrMobjr;r.r.r/get_command_infos zCeleryCommand.get_command_infoc szdurtnj}g}tD]$\}}|td||dfdd|Ddgqd| S)Nz+ {0}:  c3s(|]}j|ddVqdS)rN)r).0rBrMrarrLrr.r/ s z.CeleryCommand.list_commands..) rrLwhitecommand_classesrtrrrIrstrip)rarrLrMrr- command_clsrNr.rr/rSszCeleryCommand.list_commandscCs0t|dkrd|ddvrdgdgfSdSdS)Nrgrrrz-Pz--pool)rqrr.r.r/with_pool_options zCeleryCommand.with_pool_optioncCs |dSr))load_extension_commandsr@r.r.r/on_concurrency_setups z"CeleryCommand.on_concurrency_setupcCs6t|jj|d|j}|rtd|dfdSdS)Nrrrn)rext_fmtrIrdloadrrs)r@rr.r.r/rsz%CeleryCommand.load_extension_commandsr))r)rNNN)rNN)*r3rDrErFrr r r rrrHr rrrr!rr'rrrrrrNrenable_config_from_cmdlinerA namespace classmethodrdrlrfr{r}rr8rrSrrrr_r.r.r\r/rwsz         %    rr1r))sX                   -