(self, data)
| 32 | return self._async_storage |
| 33 | |
| 34 | async def write(self, data): |
| 35 | if self.wrap_in_ray: |
| 36 | await self.storage.write.remote(data) |
| 37 | else: |
| 38 | storage = await self._get_async_storage() |
| 39 | await storage.write(data) |
| 40 | |
| 41 | async def acquire(self) -> int: |
| 42 | if self.wrap_in_ray: |