MCPcopy
hub / github.com/ray-project/ray / remaining_processes_alive

Method remaining_processes_alive

python/ray/_private/node.py:1800–1809  ·  view source on GitHub ↗

Return true if all remaining processes are still alive. Note that this ignores processes that have been explicitly killed, e.g., via a command like node.kill_raylet(). Returns: True if any process that wasn't explicitly killed is still alive.

(self)

Source from the content-addressed store, hash-verified

1798 return any(self.live_processes())
1799
1800 def remaining_processes_alive(self):
1801 """Return true if all remaining processes are still alive.
1802
1803 Note that this ignores processes that have been explicitly killed,
1804 e.g., via a command like node.kill_raylet().
1805
1806 Returns:
1807 True if any process that wasn't explicitly killed is still alive.
1808 """
1809 return not any(self.dead_processes())
1810
1811 def destroy_external_storage(self):
1812 object_spilling_config = self._config.get("object_spilling_config", {})

Callers 14

test_clusterFunction · 0.45
test_dying_workerFunction · 0.45
test_getting_and_puttingFunction · 0.45
test_submitting_tasksFunction · 0.45
test_dependenciesFunction · 0.45
test_waitFunction · 0.45
test_dying_worker_getFunction · 0.45
test_dying_driver_getFunction · 0.45

Calls 1

dead_processesMethod · 0.95

Tested by 13

test_clusterFunction · 0.36
test_dying_workerFunction · 0.36
test_getting_and_puttingFunction · 0.36
test_submitting_tasksFunction · 0.36
test_dependenciesFunction · 0.36
test_waitFunction · 0.36
test_dying_worker_getFunction · 0.36
test_dying_driver_getFunction · 0.36
test_dying_worker_waitFunction · 0.36