Method execute

pkg/devspace/hook/wait.go:64–110

(ctx context.Context, hook *latest.HookConfig, client kubectl.Client, imageSelector []imageselector.ImageSelector, log logpkg.Logger)

}

func (r *waitHook) execute(ctx context.Context, hook *latest.HookConfig, client kubectl.Client, imageSelector []imageselector.ImageSelector, log logpkg.Logger) error {
	labelSelector := ""
	if len(hook.Container.LabelSelector) > 0 {
		labelSelector = labels.Set(hook.Container.LabelSelector).String()
	}

	timeout := int64(150)
	if hook.Wait.Timeout > 0 {
		timeout = hook.Wait.Timeout
	}

	// wait until the defined condition will be true, this will wait initially 2 seconds
	err := wait.PollUntilContextTimeout(ctx, time.Second*2, time.Duration(timeout)*time.Second, false, func(ctx context.Context) (done bool, err error) {
		podContainers, err := selector.NewFilter(client).SelectContainers(ctx, selector.Selector{
			ImageSelector:   targetselector.ToStringImageSelector(imageSelector),
			LabelSelector:   labelSelector,
			Pod:             hook.Container.Pod,
			ContainerName:   hook.Container.ContainerName,
			Namespace:       hook.Container.Namespace,
			FilterContainer: selector.FilterTerminatingContainers,
		})
		if err != nil {
			return false, err
		}

		// lets check if all containers satisfy the condition
		for _, pc := range podContainers {
			if targetselector.HasPodProblem(pc.Pod) {
				r.printWarning.Do(func() {
					status := kubectl.GetPodStatus(pc.Pod)
					log.Warnf("Pod %s/%s has critical status: %s. DevSpace will continue waiting, but this operation might timeout", pc.Pod.Namespace, pc.Pod.Name, status)
				})
			}

			if !isWaitConditionTrue(hook.Wait, pc) {
				return false, nil
			}
		}

		return true, nil
	})
	if err != nil {
		return err
	}

	return nil
}

func isWaitConditionTrue(condition *latest.HookWaitConfig, podContainer *selector.SelectedPodContainer) bool {
	if selector.IsPodTerminating(podContainer.Pod) {