(self)
| 296 | """Tests for SQLReader/SQLWriter async methods without Ray.""" |
| 297 | |
| 298 | def _make_config(self) -> StorageConfig: |
| 299 | config = StorageConfig() |
| 300 | config.name = "test_rw" |
| 301 | config.path = f"sqlite:///{db_path}" |
| 302 | config.schema_type = "sft" |
| 303 | config.storage_type = "sql" |
| 304 | config.wrap_in_ray = False |
| 305 | config.batch_size = 4 |
| 306 | config.max_read_timeout = 3 |
| 307 | return config |
| 308 | |
| 309 | async def test_writer_reader_roundtrip(self): |
| 310 | """Writer.write and Reader.read should work end-to-end.""" |
no test coverage detected