Execute size_bytes remotely and return result.
(self)
| 191 | return ray.get(result_ref) |
| 192 | |
| 193 | def size_bytes(self) -> int: |
| 194 | """Execute size_bytes remotely and return result.""" |
| 195 | |
| 196 | @ray.remote |
| 197 | def _remote_size_bytes(dataset): |
| 198 | return dataset.size_bytes() |
| 199 | |
| 200 | result_ref = _remote_size_bytes.remote(self._dataset_ref) |
| 201 | return ray.get(result_ref) |
| 202 | |
| 203 | def __getattr__(self, name): |
| 204 | """Catch any method calls that we haven't explicitly implemented.""" |
no test coverage detected