| 1809 | return not any(self.dead_processes()) |
| 1810 | |
| 1811 | def destroy_external_storage(self): |
| 1812 | object_spilling_config = self._config.get("object_spilling_config", {}) |
| 1813 | if object_spilling_config: |
| 1814 | object_spilling_config = json.loads(object_spilling_config) |
| 1815 | from ray._private import external_storage |
| 1816 | |
| 1817 | storage = external_storage.setup_external_storage( |
| 1818 | object_spilling_config, self._node_id, self._session_name |
| 1819 | ) |
| 1820 | storage.destroy_external_storage() |
| 1821 | |
| 1822 | def validate_external_storage(self): |
| 1823 | """Make sure we can setup the object spilling external storage.""" |