Method execute

pkg/devspace/hook/remote_hook.go:75–115

(ctx devspacecontext.Context, hook *latest.HookConfig, imageSelector []imageselector.ImageSelector)

}

func (r *remoteHook) execute(ctx devspacecontext.Context, hook *latest.HookConfig, imageSelector []imageselector.ImageSelector) (bool, error) {
	labelSelector := ""
	if len(hook.Container.LabelSelector) > 0 {
		labelSelector = labels.Set(hook.Container.LabelSelector).String()
	}

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

	wait := false
	if hook.Container.Wait == nil || *hook.Container.Wait {
		ctx.Log().Infof("Waiting for running containers for hook '%s'", ansi.Color(hookName(hook), "white+b"))
		wait = true
	}

	// build target selector
	targetSelectorOptions := targetselector.NewOptionsFromFlags(hook.Container.ContainerName, labelSelector, targetselector.ToStringImageSelector(imageSelector), hook.Container.Namespace, hook.Container.Pod).
		WithTimeout(timeout).
		WithWait(wait).
		WithWaitingStrategy(r.WaitingStrategy)

	// select container
	podContainer, err := targetselector.NewTargetSelector(targetSelectorOptions).SelectSingleContainer(ctx.Context(), ctx.KubeClient(), ctx.Log())
	if err != nil {
		if _, ok := err.(*targetselector.NotFoundErr); ok {
			return false, nil
		}

		return false, err
	}

	// execute the hook in the container
	err = r.Hook.ExecuteRemotely(ctx, hook, podContainer)
	if err != nil {
		return false, err
	}

	return true, nil
}