(self)
| 243 | """Tests for SQLTaskStorage (async primary class).""" |
| 244 | |
| 245 | def _make_config(self) -> StorageConfig: |
| 246 | config = StorageConfig() |
| 247 | config.name = "test_task" |
| 248 | config.path = f"sqlite:///{db_path}" |
| 249 | config.schema_type = None |
| 250 | config.storage_type = "sql" |
| 251 | config.wrap_in_ray = False |
| 252 | config.batch_size = 4 |
| 253 | config.max_read_timeout = 5 |
| 254 | config.default_workflow_type = "math_workflow" |
| 255 | return config |
| 256 | |
| 257 | async def test_write_and_read_tasks(self): |
| 258 | """Write tasks and read them back.""" |
no test coverage detected