Skip to content

Commit b7f9d5a

Browse files
committed
Upate deletePolicyHandler to just delete benchmark policy
1 parent 258a835 commit b7f9d5a

File tree

1 file changed

+9
-17
lines changed

1 file changed

+9
-17
lines changed

internal/benchrunner/runners/system/runner.go

Lines changed: 9 additions & 17 deletions
Original file line numberDiff line numberDiff line change
@@ -495,31 +495,23 @@ func (r *runner) createBenchmarkPolicy(ctx context.Context, pkgManifest *package
495495
return nil, err
496496
}
497497

498-
packagePolicy, err := r.createPackagePolicy(ctx, pkgManifest, policy)
499-
if err != nil {
500-
return nil, err
501-
}
502-
503498
r.deletePolicyHandler = func(ctx context.Context) error {
504-
var merr multierror.Error
505-
506-
logger.Debug("deleting benchmark package policy...")
507-
if err := r.options.KibanaClient.DeletePackagePolicy(ctx, *packagePolicy); err != nil {
508-
merr = append(merr, fmt.Errorf("error cleaning up benchmark package policy: %w", err))
509-
}
510-
499+
// Package policy deletion is handled when deleting this policy.
500+
// Setting here the deletion handler ensures that if package policy creation fails,
501+
// no orphaned package policies are left behind.
511502
logger.Debug("deleting benchmark policy...")
512503
if err := r.options.KibanaClient.DeletePolicy(ctx, policy.ID); err != nil {
513-
merr = append(merr, fmt.Errorf("error cleaning up benchmark policy: %w", err))
514-
}
515-
516-
if len(merr) > 0 {
517-
return merr
504+
return fmt.Errorf("error cleaning up benchmark policy: %w", err)
518505
}
519506

520507
return nil
521508
}
522509

510+
_, err = r.createPackagePolicy(ctx, pkgManifest, policy)
511+
if err != nil {
512+
return nil, err
513+
}
514+
523515
return policy, nil
524516
}
525517

0 commit comments

Comments
 (0)