_celery
5993 bytes
1#compdef celery
2#autoload
3
4#celery zsh completion
5
6_celery () {
7local -a _1st_arguments ifargs dopts controlargs
8
9typeset -A opt_args
10
11_1st_arguments=('worker' 'events' 'beat' 'shell' 'multi' 'amqp' 'status' 'inspect' \
12 'control' 'purge' 'list' 'migrate' 'call' 'result' 'report')
13ifargs=('--app=' '--broker=' '--loader=' '--config=' '--version')
14dopts=('--detach' '--umask=' '--gid=' '--uid=' '--pidfile=' '--logfile=' '--loglevel=')
15controlargs=('--timeout' '--destination')
16_arguments \
17 '(-A --app=)'{-A,--app}'[app instance to use (e.g. module.attr_name):APP]' \
18 '(-b --broker=)'{-b,--broker}'[url to broker. default is "amqp://guest@localhost//":BROKER]' \
19 '(--loader)--loader[name of custom loader class to use.:LOADER]' \
20 '(--config)--config[Name of the configuration module:CONFIG]' \
21 '(--workdir)--workdir[Optional directory to change to after detaching.:WORKING_DIRECTORY]' \
22 '(-q --quiet)'{-q,--quiet}'[Don"t show as much output.]' \
23 '(-C --no-color)'{-C,--no-color}'[Don"t display colors.]' \
24 '(--version)--version[show program"s version number and exit]' \
25 '(- : *)'{-h,--help}'[show this help message and exit]' \
26 '*:: :->subcmds' && return 0
27
28if (( CURRENT == 1 )); then
29 _describe -t commands "celery subcommand" _1st_arguments
30 return
31fi
32
33case "$words[1]" in
34 worker)
35 _arguments \
36 '(-C --concurrency=)'{-C,--concurrency=}'[Number of child processes processing the queue. The default is the number of CPUs.]' \
37 '(--pool)--pool=:::(processes eventlet gevent threads solo)' \
38 '(--purge --discard)'{--discard,--purge}'[Purges all waiting tasks before the daemon is started.]' \
39 '(-f --logfile=)'{-f,--logfile=}'[Path to log file. If no logfile is specified, stderr is used.]' \
40 '(--loglevel=)--loglevel=:::(critical error warning info debug)' \
41 '(-N --hostname=)'{-N,--hostname=}'[Set custom hostname, e.g. "foo.example.com".]' \
42 '(-B --beat)'{-B,--beat}'[Also run the celerybeat periodic task scheduler.]' \
43 '(-s --schedule=)'{-s,--schedule=}'[Path to the schedule database if running with the -B option. Defaults to celerybeat-schedule.]' \
44 '(-S --statedb=)'{-S,--statedb=}'[Path to the state database.Default: None]' \
45 '(-E --events)'{-E,--events}'[Send events that can be captured by monitors like celeryev, celerymon, and others.]' \
46 '(--time-limit=)--time-limit=[nables a hard time limit (in seconds int/float) for tasks]' \
47 '(--soft-time-limit=)--soft-time-limit=[Enables a soft time limit (in seconds int/float) for tasks]' \
48 '(--maxtasksperchild=)--maxtasksperchild=[Maximum number of tasks a pool worker can execute before it"s terminated and replaced by a new worker.]' \
49 '(-Q --queues=)'{-Q,--queues=}'[List of queues to enable for this worker, separated by comma. By default all configured queues are enabled.]' \
50 '(-I --include=)'{-I,--include=}'[Comma separated list of additional modules to import.]' \
51 '(--pidfile=)--pidfile=[Optional file used to store the process pid.]' \
52 '(--autoscale=)--autoscale=[Enable autoscaling by providing max_concurrency, min_concurrency.]' \
53 '(--autoreload)--autoreload[Enable autoreloading.]' \
54 '(--no-execv)--no-execv[Don"t do execv after multiprocessing child fork.]'
55 compadd -a ifargs
56 ;;
57 inspect)
58 _values -s \
59 'active[dump active tasks (being processed)]' \
60 'active_queues[dump queues being consumed from]' \
61 'ping[ping worker(s)]' \
62 'registered[dump of registered tasks]' \
63 'report[get bugreport info]' \
64 'reserved[dump reserved tasks (waiting to be processed)]' \
65 'revoked[dump of revoked task ids]' \
66 'scheduled[dump scheduled tasks (eta/countdown/retry)]' \
67 'stats[dump worker statistics]'
68 compadd -a controlargs ifargs
69 ;;
70 control)
71 _values -s \
72 'add_consumer[tell worker(s) to start consuming a queue]' \
73 'autoscale[change autoscale settings]' \
74 'cancel_consumer[tell worker(s) to stop consuming a queue]' \
75 'disable_events[tell worker(s) to disable events]' \
76 'enable_events[tell worker(s) to enable events]' \
77 'pool_grow[start more pool processes]' \
78 'pool_shrink[use less pool processes]' \
79 'rate_limit[tell worker(s) to modify the rate limit for a task type]' \
80 'time_limit[tell worker(s) to modify the time limit for a task type.]'
81 compadd -a controlargs ifargs
82 ;;
83 multi)
84 _values -s \
85 '--nosplash[Don"t display program info.]' \
86 '--verbose[Show more output.]' \
87 '--no-color[Don"t display colors.]' \
88 '--quiet[Don"t show as much output.]' \
89 'start' 'restart' 'stopwait' 'stop' 'show' \
90 'names' 'expand' 'get' 'kill'
91 compadd -a ifargs
92 ;;
93 amqp)
94 _values -s \
95 'queue.declare' 'queue.purge' 'exchange.delete' 'basic.publish' \
96 'exchange.declare' 'queue.delete' 'queue.bind' 'basic.get'
97 ;;
98 list)
99 _values -s, 'bindings'
100 ;;
101 shell)
102 _values -s \
103 '--ipython[force iPython.]' \
104 '--bpython[force bpython.]' \
105 '--python[force default Python shell.]' \
106 '--without-tasks[don"t add tasks to locals.]' \
107 '--eventlet[use eventlet.]' \
108 '--gevent[use gevent.]'
109 compadd -a ifargs
110 ;;
111 beat)
112 _arguments \
113 '(-s --schedule=)'{-s,--schedule=}'[Path to the schedule database. Defaults to celerybeat-schedule.]' \
114 '(-S --scheduler=)'{-S,--scheduler=}'[Scheduler class to use. Default is celery.beat.PersistentScheduler.]' \
115 '(--max-interval)--max-interval[]'
116 compadd -a dopts fargs
117 ;;
118 events)
119 _arguments \
120 '(-d --dump)'{-d,--dump}'[Dump events to stdout.]' \
121 '(-c --camera=)'{-c,--camera=}'[Take snapshots of events using this camera.]' \
122 '(-F --frequency=)'{-F,--frequency=}'[Camera: Shutter frequency. Default is every 1.0 seconds.]' \
123 '(-r --maxrate=)'{-r,--maxrate=}'[Camera: Optional shutter rate limit (e.g. 10/m).]'
124 compadd -a dopts fargs
125 ;;
126 *)
127 ;;
128 esac
129}