| 1286 | }) |
| 1287 | |
| 1288 | func (e *Executor) SchemaDrop(ctx context.Context, params *riverdriver.SchemaDropParams) error { |
| 1289 | for _, possibleExtension := range possibleExtensions { |
| 1290 | if err := os.Remove(fmt.Sprintf("%s/%s.%s", sqliteTestDir(), params.Schema, possibleExtension)); !os.IsNotExist(err) { |
| 1291 | return err |
| 1292 | } |
| 1293 | } |
| 1294 | |
| 1295 | return nil |
| 1296 | } |
| 1297 | |
| 1298 | func (e *Executor) SchemaGetExpired(ctx context.Context, params *riverdriver.SchemaGetExpiredParams) ([]string, error) { |
| 1299 | if err := os.MkdirAll(sqliteTestDir(), 0o700); err != nil { |