From 9196770fb36c46cc6f98165779efb66d7dbea56a Mon Sep 17 00:00:00 2001 From: Jiaxin Yan Date: Tue, 21 Jan 2025 13:14:42 +0800 Subject: [PATCH] upsert plan state bug fix --- .../managers/solution/solution-manager.go | 25 ++++++++++++++++--- 1 file changed, 22 insertions(+), 3 deletions(-) diff --git a/api/pkg/apis/v1alpha1/managers/solution/solution-manager.go b/api/pkg/apis/v1alpha1/managers/solution/solution-manager.go index 6838e7cd8..6959e3c51 100644 --- a/api/pkg/apis/v1alpha1/managers/solution/solution-manager.go +++ b/api/pkg/apis/v1alpha1/managers/solution/solution-manager.go @@ -282,9 +282,28 @@ func (s *SolutionManager) HandleDeploymentPlan(ctx context.Context, event v1alph func (s *SolutionManager) upsertPlanState(ctx context.Context, planId string, planState *PlanState) error { upsertRequest := states.UpsertRequest{ Value: states.StateEntry{ - ID: planId, - Body: planState}, - } + ID: planId, + Body: map[string]interface{}{ + "ID": planState.ID, + "PlanId": planState.PlanId, + "Phase": planState.Phase, + "StartTime": planState.StartTime, + "ExpireTime": planState.ExpireTime, + "TotalSteps": planState.TotalSteps, + "CompletedSteps": planState.CompletedSteps, + "Summary": planState.Summary, + "MergedState": planState.MergedState, + "Deployment": planState.Deployment, + "CurrentState": planState.CurrentState, + "PreviousDesiredState": planState.PreviousDesiredState, + "Status": planState.Status, + "TargetResult": planState.TargetResult, + "Namespace": planState.Namespace, + "Remove": planState.Remove, + "StepStates": planState.StepStates, + "Steps": planState.Steps, + }, + }} _, err := s.StateProvider.Upsert(ctx, upsertRequest) return err }