1

Author: aledbf

components/ws-manager/pkg/manager/manager.go

@@ -314,7 +314,7 @@ func (m *Manager) StartWorkspace(_ context.Context, req *api.StartWorkspaceReque
 		return nil, err
 	}
 
-	err = wait.PollWithContext(ctx, 100*time.Millisecond, 10*time.Minute, podRunning(m.Clientset, pod.Name, pod.Namespace))
+	err = wait.PollImmediateWithContext(ctx, 100*time.Millisecond, 10*time.Minute, podRunning(m.Clientset, pod.Name, pod.Namespace))
 	if err != nil {
 		return nil, xerrors.Errorf("workspace pod never reached Running state: %w", err)
 	}
@@ -326,7 +326,7 @@ func (m *Manager) StartWorkspace(_ context.Context, req *api.StartWorkspaceReque
 			return nil, xerrors.Errorf("unable to get workspace pod %s: %w", pod.Name, err)
 		}
 
-		err = wait.PollWithContext(ctx, 100*time.Millisecond, 5*time.Minute, pvcRunning(m.Clientset, pvc.Name, pvc.Namespace))
+		err = wait.PollImmediateWithContext(ctx, 100*time.Millisecond, 5*time.Minute, pvcRunning(m.Clientset, pvc.Name, pvc.Namespace))
 		if err != nil {
 			if startContext.VolumeSnapshot != nil && startContext.VolumeSnapshot.VolumeSnapshotName != "" {
 				m.eventRecorder.Eventf(pod, corev1.EventTypeWarning, "PersistentVolumeClaim", "PVC %q restore from volume snapshot %q failed %v", pvc.Name, startContext.VolumeSnapshot.VolumeSnapshotName, err)