fix integration tests

Author: TiberiuGC

pkg/actions/addon/tasks.go

@@ -119,15 +119,15 @@ type deleteAddonIAMTask struct {
 func (t *deleteAddonIAMTask) Describe() string { return t.info }
 
 func (t *deleteAddonIAMTask) Do(errorCh chan error) error {
-	defer close(errorCh)
-
 	errMsg := fmt.Sprintf("deleting addon IAM %q", *t.stack.StackName)
 	if t.wait {
 		if err := t.stackManager.DeleteStackBySpecSync(t.ctx, t.stack, errorCh); err != nil {
 			return fmt.Errorf("%s: %w", errMsg, err)
 		}
 		return nil
 	}
+
+	defer close(errorCh)
 	if _, err := t.stackManager.DeleteStackBySpec(t.ctx, t.stack); err != nil {
 		return fmt.Errorf("%s: %w", errMsg, err)
 	}

pkg/actions/irsa/create.go

@@ -42,6 +42,8 @@ func NewCreator(
 	oidcManager *iamoidc.OpenIDConnectManager,
 	stackManager StackManager) *Creator {
 	return &Creator{
+		clusterName:     clusterName,
+		region:          region,
 		clientSetGetter: clientSetGetter,
 		oidcManager:     oidcManager,
 		stackManager:    stackManager,

pkg/actions/irsa/tasks.go

@@ -57,8 +57,6 @@ type createIAMRoleForServiceAccountTask struct {
 
 func (t *createIAMRoleForServiceAccountTask) Describe() string { return t.info }
 func (t *createIAMRoleForServiceAccountTask) Do(errs chan error) error {
-	defer close(errs)
-
 	name := makeIAMServiceAccountStackName(t.clusterName, t.sa.Namespace, t.sa.Name)
 	logger.Info("building iamserviceaccount stack %q", name)
 	stack := builder.NewIAMRoleResourceSetForServiceAccount(t.sa, t.oidc)
@@ -115,15 +113,15 @@ type deleteIAMRoleForServiceAccountTask struct {
 func (t *deleteIAMRoleForServiceAccountTask) Describe() string { return t.info }
 
 func (t *deleteIAMRoleForServiceAccountTask) Do(errorCh chan error) error {
-	defer close(errorCh)
-
 	errMsg := fmt.Sprintf("deleting IAM role for serviceaccount %q", *t.stack.StackName)
 	if t.wait {
 		if err := t.stackManager.DeleteStackBySpecSync(t.ctx, t.stack, errorCh); err != nil {
 			return fmt.Errorf("%s: %w", errMsg, err)
 		}
 		return nil
 	}
+
+	defer close(errorCh)
 	if _, err := t.stackManager.DeleteStackBySpec(t.ctx, t.stack); err != nil {
 		return fmt.Errorf("%s: %w", errMsg, err)
 	}