From 9bd5b3e5e99f0b2fae009a5f4a7148286559ec71 Mon Sep 17 00:00:00 2001 From: venkat k Date: Fri, 31 May 2024 21:59:08 +0530 Subject: [PATCH] fix plugin deploy issue with workflow --- capten/agent/internal/api/cluster_plugin_apis.go | 1 + capten/deployment-worker/internal/activities/plugin_activity.go | 2 -- capten/deployment-worker/internal/workflows/plugin_workflow.go | 1 + 3 files changed, 2 insertions(+), 2 deletions(-) diff --git a/capten/agent/internal/api/cluster_plugin_apis.go b/capten/agent/internal/api/cluster_plugin_apis.go index b9f96b87..f69b793d 100644 --- 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 index b6408e8e..69f8d1de 100644 --- 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 index 68233701..d0a53848 100644 --- 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)