(self, name,
cmd=None, append=None, options=None, extra_args=None)
| 123 | """Represents a node in a cluster.""" |
| 124 | |
| 125 | def __init__(self, name, |
| 126 | cmd=None, append=None, options=None, extra_args=None): |
| 127 | self.name = name |
| 128 | self.cmd = cmd or f"-m {celery_exe('worker', '--detach')}" |
| 129 | self.append = append |
| 130 | self.extra_args = extra_args or '' |
| 131 | self.options = self._annotate_with_default_opts( |
| 132 | options or OrderedDict()) |
| 133 | self.expander = self._prepare_expander() |
| 134 | self.argv = self._prepare_argv() |
| 135 | self._pid = None |
| 136 | |
| 137 | def _annotate_with_default_opts(self, options): |
| 138 | options['-n'] = self.name |
nothing calls this directly
no test coverage detected