diff --git a/engine/version.go b/engine/version.go index 28c6fbf01..ac21dde90 100644 --- a/engine/version.go +++ b/engine/version.go @@ -140,7 +140,7 @@ func CurrentDataDBVersions() Versions { utils.Accounts: 3, utils.Actions: 2, utils.ActionTriggers: 2, - utils.ActionPlans: 2, + utils.ActionPlans: 3, utils.SharedGroups: 2, utils.Thresholds: 3, utils.Suppliers: 1, diff --git a/migrator/action_plan.go b/migrator/action_plan.go index 0999e802c..8a67b1061 100644 --- a/migrator/action_plan.go +++ b/migrator/action_plan.go @@ -140,6 +140,15 @@ func (m *Migrator) migrateActionPlans() (err error) { if err = m.migrateCurrentActionPlans(); err != nil { return err } + case 2: // neded to rebuild action plan indexes for redis + // All done, update version wtih current one + vrs := engine.Versions{utils.ActionPlans: engine.CurrentDataDBVersions()[utils.ActionPlans]} + if err = m.dmOut.DataManager().DataDB().SetVersions(vrs, false); err != nil { + return utils.NewCGRError(utils.Migrator, + utils.ServerErrorCaps, + err.Error(), + fmt.Sprintf("error: <%s> when updating ActionPlans version into dataDB", err.Error())) + } case 1: if err = m.migrateV1ActionPlans(); err != nil { return err