(self)
| 23 | return self._storage |
| 24 | |
| 25 | async def _get_async_storage(self): |
| 26 | if self._async_storage is None: |
| 27 | if self._config.schema_type is None: |
| 28 | self._async_storage = SQLTaskStorage(self._config) |
| 29 | else: |
| 30 | self._async_storage = SQLExperienceStorage(self._config) |
| 31 | await self._async_storage.prepare() |
| 32 | return self._async_storage |
| 33 | |
| 34 | async def write(self, data): |
| 35 | if self.wrap_in_ray: |
no test coverage detected