(self)
| 27 | return self._storage |
| 28 | |
| 29 | async def _get_async_storage(self): |
| 30 | if self._async_storage is None: |
| 31 | if self._config.schema_type is None: |
| 32 | self._async_storage = SQLTaskStorage(self._config) |
| 33 | else: |
| 34 | self._async_storage = SQLExperienceStorage(self._config) |
| 35 | await self._async_storage.prepare() |
| 36 | return self._async_storage |
| 37 | |
| 38 | async def read(self, batch_size: Optional[int] = None, **kwargs) -> List: |
| 39 | batch_size = self.read_batch_size if batch_size is None else batch_size |
no test coverage detected