make pulumi refresh configurable.

nitrictech · Feb 13, 2024 · 1f6a6a8 · 1f6a6a8
1 parent 16f3930
commit 1f6a6a8
Show file tree

Hide file tree

Showing 2 changed files with 67 additions and 5 deletions.
diff --git a/cloud/common/deploy/provider/pulumi.go b/cloud/common/deploy/provider/pulumi.go
@@ -172,7 +172,9 @@ func (s *PulumiProviderServer) Up(req *deploymentspb.DeploymentUpRequest, stream
 		return err
 	}
 
-	err = s.provider.Init(req.Attributes.AsMap())
+	attributesMap := req.Attributes.AsMap()
+
+	err = s.provider.Init(attributesMap)
 	if err != nil {
 		return err
 	}
@@ -201,10 +203,15 @@ func (s *PulumiProviderServer) Up(req *deploymentspb.DeploymentUpRequest, stream
 		return err
 	}
 
-	_, err = autoStack.Refresh(context.TODO())
-	if err != nil {
-		logger.Errorf(err.Error())
-		return err
+	refresh, ok := attributesMap["refresh"].(bool)
+
+	if ok && refresh {
+		logger.Info("refreshing pulumi stack")
+		_, err = autoStack.Refresh(context.TODO())
+		if err != nil {
+			logger.Errorf(err.Error())
+			return err
+		}
 	}
 
 	result, err := autoStack.Up(context.TODO(), optup.EventStreams(pulumiEventsChan))