4.7.2

internal/service/cloudapi/flipgroup/data_source_flipgroup_list.go

@@ -124,7 +124,7 @@ func dataSourceFlipgroupListSchemaMake() map[string]*schema.Schema {
 			Type:     schema.TypeList,
 			Optional: true,
 			Elem: &schema.Schema{
-				Type: schema.TypeString,
+				Type: schema.TypeInt,
 			},
 			Description: "client_ids",
 		},

internal/service/cloudapi/flipgroup/utility_flipgroup.go

@@ -189,7 +189,7 @@ func utilityFlipgroupListCheckPresence(ctx context.Context, d *schema.ResourceDa
 	if cliensId, ok := d.GetOk("client_ids"); ok {
 		cliensIds := cliensId.([]interface{})
 		for _, elem := range cliensIds {
-			req.ClientIDs = append(req.ClientIDs, (elem.(string)))
+			req.ClientIDs = append(req.ClientIDs, uint64(elem.(int)))
 		}
 	}
 	if status, ok := d.GetOk("status"); ok {

internal/service/cloudapi/k8s/resource_k8s_wg.go

@@ -37,6 +37,7 @@ import (
 	"fmt"
 	"strconv"
 	"strings"
+	"time"
 
 	"github.com/hashicorp/terraform-plugin-sdk/v2/diag"
 	"github.com/hashicorp/terraform-plugin-sdk/v2/helper/schema"
@@ -44,6 +45,7 @@ import (
 	log "github.com/sirupsen/logrus"
 	"repository.basistech.ru/BASIS/decort-golang-sdk/pkg/cloudapi/compute"
 	"repository.basistech.ru/BASIS/decort-golang-sdk/pkg/cloudapi/k8s"
+	"repository.basistech.ru/BASIS/decort-golang-sdk/pkg/cloudapi/tasks"
 	"repository.basistech.ru/BASIS/terraform-provider-decort/internal/constants"
 	"repository.basistech.ru/BASIS/terraform-provider-decort/internal/controller"
 	"repository.basistech.ru/BASIS/terraform-provider-decort/internal/validators"
@@ -105,7 +107,33 @@ func resourceK8sWgCreate(ctx context.Context, d *schema.ResourceData, m interfac
 		return diag.FromErr(err)
 	}
 
-	d.SetId(fmt.Sprintf("%d#%d", d.Get("k8s_id").(int), resp))
+	taskReq := tasks.GetRequest{
+		AuditID: strings.Trim(resp, `"`),
+	}
+
+	for {
+		task, err := c.CloudAPI().Tasks().Get(ctx, taskReq)
+		if err != nil {
+			return diag.FromErr(err)
+		}
+
+		log.Debugf("resourceK8sWgCreate: instance creating - %s", task.Stage)
+
+		if task.Completed {
+			if task.Error != "" {
+				return diag.FromErr(fmt.Errorf("cannot create k8s wg instance: %v", task.Error))
+			}
+
+			id, err := task.Result.ID()
+			if err != nil {
+				return diag.FromErr(err)
+			}
+			d.SetId(fmt.Sprint(d.Get("k8s_id").(int), "#", strconv.Itoa(id)))
+			break
+		}
+
+		time.Sleep(time.Second * 20)
+	}
 
 	return resourceK8sWgRead(ctx, d, m)
 }