add RetryInterval on all wait functions

Author: Mia-Cross

internal/namespaces/block/v1alpha1/custom_snapshot.go

@@ -80,8 +80,9 @@ func blockSnapshotCreateBuilder(c *core.Command) *core.Command {
 		resp := respI.(*block.Snapshot)
 
 		return block.NewAPI(core.ExtractClient(ctx)).WaitForSnapshot(&block.WaitForSnapshotRequest{
-			SnapshotID: resp.ID,
-			Zone:       resp.Zone,
+			SnapshotID:    resp.ID,
+			Zone:          resp.Zone,
+			RetryInterval: core.DefaultRetryInterval,
 		})
 	}
 

internal/namespaces/block/v1alpha1/custom_volume.go

@@ -79,8 +79,9 @@ func blockVolumeCreateBuilder(c *core.Command) *core.Command {
 		resp := respI.(*block.Volume)
 
 		return block.NewAPI(core.ExtractClient(ctx)).WaitForVolume(&block.WaitForVolumeRequest{
-			VolumeID: resp.ID,
-			Zone:     resp.Zone,
+			VolumeID:      resp.ID,
+			Zone:          resp.Zone,
+			RetryInterval: core.DefaultRetryInterval,
 		})
 	}
 

internal/namespaces/function/v1beta1/custom_deploy.go

@@ -166,8 +166,9 @@ func DeployStepCreateNamespace(
 		})
 
 		namespace, err = api.WaitForNamespace(&function.WaitForNamespaceRequest{
-			NamespaceID: namespace.ID,
-			Region:      namespace.Region,
+			NamespaceID:   namespace.ID,
+			Region:        namespace.Region,
+			RetryInterval: core.DefaultRetryInterval,
 		})
 		if err != nil {
 			return nil, fmt.Errorf("could not fetch created namespace: %w", err)

internal/namespaces/instance/v1/custom_image.go

@@ -334,6 +334,7 @@ func imageDeleteBuilder(c *core.Command) *core.Command {
 							SnapshotID:     snapshot.ID,
 							Zone:           args.Zone,
 							TerminalStatus: &terminalStatus,
+							RetryInterval:  core.DefaultRetryInterval,
 						})
 						if err != nil {
 							return nil, err

internal/namespaces/instance/v1/custom_server_action.go

@@ -419,6 +419,7 @@ func serverTerminateCommand() *core.Command {
 						VolumeID:       volume.ID,
 						Zone:           volume.Zone,
 						TerminalStatus: &terminalStatus,
+						RetryInterval:  core.DefaultRetryInterval,
 					})
 					if err != nil {
 						return nil, fmt.Errorf("failed to wait for block volume %s: %w", volume.ID, err)

internal/namespaces/instance/v1/custom_server_create_test.go

@@ -454,8 +454,9 @@ func Test_CreateServer(t *testing.T) {
 
 					api := blockSDK.NewAPI(ctx.Client)
 					vol, err := api.WaitForVolume(&blockSDK.WaitForVolumeRequest{
-						VolumeID: rootVolume.ID,
-						Zone:     rootVolume.Zone,
+						VolumeID:      rootVolume.ID,
+						Zone:          rootVolume.Zone,
+						RetryInterval: core.DefaultRetryInterval,
 					})
 					require.NoError(t, err)
 					assert.NotNil(t, vol.Specs)

internal/namespaces/rdb/v1/custom_endpoint.go

@@ -125,8 +125,9 @@ func endpointCreateBuilder(c *core.Command) *core.Command {
 		args := argsI.(*rdbCreateEndpointRequestCustom)
 
 		instance, err := api.WaitForInstance(&rdb.WaitForInstanceRequest{
-			InstanceID: args.InstanceID,
-			Region:     args.Region,
+			InstanceID:    args.InstanceID,
+			Region:        args.Region,
+			RetryInterval: core.DefaultRetryInterval,
 		}, scw.WithContext(ctx))
 		if err != nil {
 			return nil, err