Source symbols: celery/apps/multi.py

Deterministic, value-free symbol metadata extracted from public source. Implementations and literal values are not copied into this page.

• Revision: main@97ed017c09de03612a7d9617ff4c038c00bf916b · 2026-07-19T16:04:39Z
• Declarations: 59
• Referenced calls: 82

Declared symbols

• celery_exe — def at line 24; references join, host_format, nodesplit, partial, startswith, format, replace, len, items
• build_nodename — def at line 28; references host_format, nodesplit, partial, startswith, format, replace, len, items
• build_expander — def at line 42; references partial, startswith, format, replace, len, items
• format_opt — def at line 54; references startswith, format, replace, len, items
• _kwargs_to_command_line — def at line 62; references format, replace, len, items
• NamespacedOptionParser — class at line 70; references OrderedDict, defaultdict, len, join, process_long_opt, process_short_opt, append, split, add_option
• __init__ — def at line 72; references OrderedDict, defaultdict
• parse — def at line 79; references len, join, process_long_opt, process_short_opt, append
• process_long_opt — def at line 100; references split, add_option
• process_short_opt — def at line 105; references add_option
• optmerge — def at line 108; references OrderedDict
• add_option — def at line 113; references split
• Node — class at line 122; references _annotate_with_default_opts, OrderedDict, _prepare_expander, _prepare_argv, _setdefaultopt, setdefault, normpath, dirname, exists, makedirs, split, build_expander, expander, index, copy, items, insert, format_opt, pop, join
• __init__ — def at line 125; references _annotate_with_default_opts, OrderedDict, _prepare_expander, _prepare_argv
• _annotate_with_default_opts — def at line 137; references _setdefaultopt
• _setdefaultopt — def at line 144; references setdefault, normpath, dirname, exists, makedirs
• _prepare_expander — def at line 156; references split, build_expander
• _prepare_argv — def at line 161; references expander, split, index, copy, items, insert, format_opt, pop, join, tuple
• alive — def at line 192; references send
• send — def at line 195; references kill, maybe_call
• start — def at line 211; references _waitexec
• _waitexec — def at line 215; references prepare_argv, maybe_call, join, Popen, handle_process_exit, wait
• handle_process_exit — def at line 226; references maybe_call
• prepare_argv — def at line 234; references join, list, split, from_utf8
• getopt — def at line 238; references KeyError
• __repr__ — def at line 246
• pidfile — def at line 250; references expander, getopt
• logfile — def at line 254; references expander, getopt
• pid — def at line 258; references Pidfile, read_pid
• pid — def at line 267
• executable — def at line 271
• argv_with_executable — def at line 275
• from_kwargs — def at line 279; references cls, _kwargs_to_command_line
• maybe_call — def at line 283; references fun
• MultiParser — class at line 288; references dict, len, pop, gethostname, _get_ranges, _update_ns_opts, _update_ns_ranges, _node_from_options, build_nodename, Node, optmerge, int, str, range, list, items, isdigit, KeyError, update, _parse_ns_range
• __init__ — def at line 291
• parse — def at line 300; references dict, len, pop, gethostname, _get_ranges, _update_ns_opts, _update_ns_ranges, _node_from_options
• _node_from_options — def at line 326; references build_nodename, Node, optmerge
• _get_ranges — def at line 333; references int, str, range
• _update_ns_opts — def at line 337; references list, items, isdigit, int, KeyError, update
• _update_ns_ranges — def at line 350; references list, items, _parse_ns_range, update, pop
• _parse_ns_range — def at line 357; references split, extend, str, range, int, append
• Cluster — class at line 370; references celery_exe, start_node, maybe_call, _start_node, start, getpids, signal_name, send, send_all, append, _stop_nodes, list, shutdown_nodes, set, add, alive, len, sleep, float, KeyError
• __init__ — def at line 373; references celery_exe
• start — def at line 409; references start_node
• start_node — def at line 412; references maybe_call, _start_node
• _start_node — def at line 418; references start
• send_all — def at line 426; references getpids, maybe_call, signal_name, send
• kill — def at line 431; references send_all
• restart — def at line 434; references maybe_call, _start_node, append, _stop_nodes
• restart_on_down — def at line 437; references maybe_call, _start_node, append, _stop_nodes
• stop — def at line 446; references _stop_nodes
• stopwait — def at line 449; references _stop_nodes
• _stop_nodes — def at line 452; references list, getpids, shutdown_nodes, maybe_call
• shutdown_nodes — def at line 459; references set, maybe_call, signal_name, send, add, alive, len, sleep, float
• find — def at line 488; references KeyError
• getpids — def at line 494; references maybe_call
• __repr__ — def at line 501; references format, len, saferepr, type
• data — def at line 508

File-level call references

• join — line 25
• host_format — line 31
• nodesplit — line 32
• partial — line 43
• startswith — line 57
• format — line 64
• replace — line 64
• len — line 65
• items — line 66
• OrderedDict — line 74
• defaultdict — line 77
• process_long_opt — line 89
• process_short_opt — line 95
• append — line 97
• split — line 102
• add_option — line 103
• _annotate_with_default_opts — line 131
• _prepare_expander — line 133
• _prepare_argv — line 134
• _setdefaultopt — line 139
• setdefault — line 150
• normpath — line 150
• dirname — line 151
• exists — line 152
• makedirs — line 153
• build_expander — line 158
• expander — line 162
• index — line 163
• copy — line 165
• insert — line 177
• format_opt — line 177
• pop — line 179
• tuple — line 182
• send — line 193
• kill — line 199
• maybe_call — line 206
• _waitexec — line 212
• prepare_argv — line 217
• Popen — line 219
• handle_process_exit — line 220
• wait — line 221
• list — line 235
• from_utf8 — line 236
• KeyError — line 244
• getopt — line 251
• Pidfile — line 262
• read_pid — line 262
• cls — line 280
• _kwargs_to_command_line — line 280
• fun — line 285
• dict — line 302
• gethostname — line 307
• _get_ranges — line 314
• _update_ns_opts — line 317
• _update_ns_ranges — line 318
• _node_from_options — line 321
• build_nodename — line 328
• Node — line 330
• optmerge — line 331
• int — line 334
• str — line 335
• range — line 335
• isdigit — line 341
• update — line 346
• _parse_ns_range — line 353
• extend — line 362
• celery_exe — line 390
• start_node — line 410
• _start_node — line 414
• start — line 419
• getpids — line 427
• signal_name — line 428
• send_all — line 432
• _stop_nodes — line 443
• shutdown_nodes — line 456
• set — line 460
• add — line 466
• alive — line 477
• sleep — line 485
• float — line 485
• saferepr — line 503
• type — line 504

Source: celery/apps/multi.py