diff --git a/gateway/apinto/strategy.go b/gateway/apinto/strategy.go index 8c4ccecc..57dd250f 100644 --- a/gateway/apinto/strategy.go +++ b/gateway/apinto/strategy.go @@ -19,11 +19,7 @@ func (s *StrategyClient) Online(ctx context.Context, resources ...*eosc.Base[gat s.client.Begin(ctx) for _, r := range resources { if r.Config.IsDelete { - err := s.client.Del(ctx, genWorkerID(r.Config.Name, gateway.ProfessionStrategy)) - if err != nil { - s.client.Rollback(ctx) - return err - } + s.client.Del(ctx, genWorkerID(r.Config.Name, gateway.ProfessionStrategy)) continue } err := s.client.Set(ctx, genWorkerID(r.Config.Name, gateway.ProfessionStrategy), r) diff --git a/module/strategy/iml.go b/module/strategy/iml.go index 92746844..44a46460 100644 --- a/module/strategy/iml.go +++ b/module/strategy/iml.go @@ -152,6 +152,9 @@ func (i *imlStrategyModule) ToPublish(ctx context.Context, driver string) ([]*st OptTime: l.UpdateAt, }) } + sort.Slice(items, func(i, j int) bool { + return items[i].Priority < items[j].Priority + }) return items, nil }