|
1 | 1 | // |
2 | 2 | // DISCLAIMER |
3 | 3 | // |
4 | | -// Copyright 2016-2023 ArangoDB GmbH, Cologne, Germany |
| 4 | +// Copyright 2016-2024 ArangoDB GmbH, Cologne, Germany |
5 | 5 | // |
6 | 6 | // Licensed under the Apache License, Version 2.0 (the "License"); |
7 | 7 | // you may not use this file except in compliance with the License. |
@@ -397,10 +397,14 @@ func (d *Reconciler) executeAction(ctx context.Context, planAction api.Action, a |
397 | 397 | d.context.CreateEvent(k8sutil.NewPlanAbortedEvent(d.context.GetAPIObject(), string(planAction.Type), planAction.MemberID, planAction.Group.AsRole())) |
398 | 398 | return false, true, false, false, nil |
399 | 399 | } else if isActionTimeout(timeout, planAction) { |
| 400 | + if planAction.Type.Optional() { |
| 401 | + log.Warn("Optional action not finished in time. Skipping") |
| 402 | + return true, false, false, false, nil |
| 403 | + } |
| 404 | + |
400 | 405 | log.Warn("Action not finished in time. Removing the entire plan") |
401 | 406 | d.context.CreateEvent(k8sutil.NewPlanTimeoutEvent(d.context.GetAPIObject(), string(planAction.Type), planAction.MemberID, planAction.Group.AsRole())) |
402 | 407 | return false, true, false, false, nil |
403 | | - |
404 | 408 | } |
405 | 409 |
|
406 | 410 | // Timeout not yet expired, come back soon |
|
0 commit comments