(self, nodes, cmd=None, env=None,
on_stopping_preamble=None,
on_send_signal=None,
on_still_waiting_for=None,
on_still_waiting_progress=None,
on_still_waiting_end=None,
on_node_start=None,
on_node_restart=None,
on_node_shutdown_ok=None,
on_node_status=None,
on_node_signal=None,
on_node_signal_dead=None,
on_node_down=None,
on_child_spawn=None,
on_child_signalled=None,
on_child_failure=None)
| 368 | """Represent a cluster of workers.""" |
| 369 | |
| 370 | def __init__(self, nodes, cmd=None, env=None, |
| 371 | on_stopping_preamble=None, |
| 372 | on_send_signal=None, |
| 373 | on_still_waiting_for=None, |
| 374 | on_still_waiting_progress=None, |
| 375 | on_still_waiting_end=None, |
| 376 | on_node_start=None, |
| 377 | on_node_restart=None, |
| 378 | on_node_shutdown_ok=None, |
| 379 | on_node_status=None, |
| 380 | on_node_signal=None, |
| 381 | on_node_signal_dead=None, |
| 382 | on_node_down=None, |
| 383 | on_child_spawn=None, |
| 384 | on_child_signalled=None, |
| 385 | on_child_failure=None): |
| 386 | self.nodes = nodes |
| 387 | self.cmd = cmd or celery_exe('worker') |
| 388 | self.env = env |
| 389 | |
| 390 | self.on_stopping_preamble = on_stopping_preamble |
| 391 | self.on_send_signal = on_send_signal |
| 392 | self.on_still_waiting_for = on_still_waiting_for |
| 393 | self.on_still_waiting_progress = on_still_waiting_progress |
| 394 | self.on_still_waiting_end = on_still_waiting_end |
| 395 | self.on_node_start = on_node_start |
| 396 | self.on_node_restart = on_node_restart |
| 397 | self.on_node_shutdown_ok = on_node_shutdown_ok |
| 398 | self.on_node_status = on_node_status |
| 399 | self.on_node_signal = on_node_signal |
| 400 | self.on_node_signal_dead = on_node_signal_dead |
| 401 | self.on_node_down = on_node_down |
| 402 | self.on_child_spawn = on_child_spawn |
| 403 | self.on_child_signalled = on_child_signalled |
| 404 | self.on_child_failure = on_child_failure |
| 405 | |
| 406 | def start(self): |
| 407 | return [self.start_node(node) for node in self] |
nothing calls this directly
no test coverage detected