Get the temp directory for the current node. Returns: The temp directory for the current node.
(self)
| 116 | return node_id.hex() |
| 117 | |
| 118 | def get_temp_dir(self) -> str: |
| 119 | """Get the temp directory for the current node. |
| 120 | |
| 121 | Returns: |
| 122 | The temp directory for the current node. |
| 123 | """ |
| 124 | assert ( |
| 125 | ray.is_initialized() |
| 126 | ), "Temp directory is not available because Ray has not been initialized." |
| 127 | return self.worker.current_temp_dir |
| 128 | |
| 129 | def get_session_name(self) -> str: |
| 130 | """Get the session name for the Ray cluster this process is connected to. |
no test coverage detected