fix plugin deploy issue with workflow

kube-tarian · May 31, 2024 · 9bd5b3e · 9bd5b3e
1 parent 0f8e275
commit 9bd5b3e
Show file tree

Hide file tree

Showing 3 changed files with 2 additions and 2 deletions.
diff --git a/capten/agent/internal/api/cluster_plugin_apis.go b/capten/agent/internal/api/cluster_plugin_apis.go
@@ -16,6 +16,7 @@ func (a *Agent) GetClusterPlugins(ctx context.Context, request *clusterpluginspb
 		}, nil
 	}
 
+	a.log.Infof("pluginConfigList: %+v", pluginConfigList)
 	clusterPlugins := []*clusterpluginspb.ClusterPlugin{}
 	for idx, pluginConfig := range pluginConfigList {
 		clusterPlugins[idx] = &clusterpluginspb.ClusterPlugin{

diff --git a/capten/deployment-worker/internal/activities/plugin_activity.go b/capten/deployment-worker/internal/activities/plugin_activity.go
@@ -63,13 +63,11 @@ func NewPluginActivities() (*PluginActivities, error) {
 
 	as, err := captenstore.NewStore(logger)
 	if err != nil {
-		logger.Errorf("failed to initialize plugin app store, %v", err)
 		return nil, err
 	}
 
 	k8sclient, err := k8s.NewK8SClient(logger)
 	if err != nil {
-		logger.Errorf("failed to get k8s client, %v", err)
 		return nil, err
 	}
 

diff --git a/capten/deployment-worker/internal/workflows/plugin_workflow.go b/capten/deployment-worker/internal/workflows/plugin_workflow.go
@@ -60,6 +60,7 @@ func setContext(ctx workflow.Context, timeInSeconds int, log logging.Logger) wor
 }
 
 func hanldeDeployWorkflow(ctx workflow.Context, payload json.RawMessage, log logging.Logger, pas *captenstore.Store) (*model.ResponsePayload, error) {
+	log.Info("Starting deploy plugin workflow")
 	var a *activities.PluginActivities
 	result := &model.ResponsePayload{}
 	ctx = setContext(ctx, 600, log)