update strategy publish bug

This commit is contained in:
Liujian
2024-12-05 15:43:42 +08:00
parent c75df95cce
commit ec6c2303be
2 changed files with 4 additions and 5 deletions
+1 -5
View File
@@ -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)