fix(admin): move w_task_executions and w_schedules migrations to admin plugin

- Include w_schedules and w_task_executions DDL in admin initial migrations for both SQLite and PostgreSQL dialects
- Remove driver-specific migration registrations from driver_asynq_worker and driver_asynq_cron
- Fix missing table error when running in Zero-Redis standalone mode without Asynq
- Update white paper table ownership mapping and ensure test cleanup
This commit is contained in:
ryan
2026-08-29 11:58:56 +08:00
parent e568b96388
commit 49f9d1076f
2 changed files with 4 additions and 0 deletions
+1
View File
@@ -121,6 +121,7 @@ func TestNewWaveletAppWithRedisEnabled(t *testing.T) {
require.NotNil(t, app)
defer func() {
_ = app.Stop(context.Background())
_ = app.Context().Dispose()
}()
require.NoError(t, app.Reconcile())
+3
View File
@@ -208,6 +208,7 @@ func TestRedisPluggability_Simulation(t *testing.T) {
stopCtx, stopCancel := context.WithTimeout(context.Background(), 5*time.Second)
defer stopCancel()
require.NoError(t, app.Stop(stopCtx))
_ = app.Context().Dispose()
})
// ══════════════════════════════════════════════════════════════════════════
@@ -235,6 +236,7 @@ func TestRedisPluggability_Simulation(t *testing.T) {
require.NoError(t, cacheSvc1.Set(context.Background(), fmt.Sprintf("seq_key_%d", i), "seq_val_unplugged", time.Minute))
require.NoError(t, appUnplugged.Stop(context.Background()))
_ = appUnplugged.Context().Dispose()
// 2. 插入 Redis 运行
appPlugged := newWaveletApp(core.ProfileAll, core.WithConfigValues(map[string]any{
@@ -253,6 +255,7 @@ func TestRedisPluggability_Simulation(t *testing.T) {
require.NoError(t, cacheSvc2.Set(context.Background(), fmt.Sprintf("seq_key_%d", i), "seq_val_plugged", time.Minute))
require.NoError(t, appPlugged.Stop(context.Background()))
_ = appPlugged.Context().Dispose()
}
})
}