Method Execute

pkg/devspace/hook/remote_hook.go:41–73

(ctx devspacecontext.Context, hook *latest.HookConfig, extraEnv map[string]string)

}

func (r *remoteHook) Execute(ctx devspacecontext.Context, hook *latest.HookConfig, extraEnv map[string]string) error {
	if ctx.KubeClient() == nil {
		return errors.Errorf("Cannot execute hook '%s': kube client is not initialized", ansi.Color(hookName(hook), "white+b"))
	}

	var (
		imageSelectors []imageselector.ImageSelector
		err            error
	)
	if hook.Container.ImageSelector != "" {
		if ctx.Config() == nil || ctx.Config().LocalCache() == nil {
			return errors.Errorf("Cannot execute hook '%s': config is not loaded", ansi.Color(hookName(hook), "white+b"))
		}

		if hook.Container.ImageSelector != "" {
			imageSelector, err := runtimevar.NewRuntimeResolver(ctx.WorkingDir(), true).FillRuntimeVariablesAsImageSelector(ctx.Context(), hook.Container.ImageSelector, ctx.Config(), ctx.Dependencies())
			if err != nil {
				return err
			}

			imageSelectors = append(imageSelectors, *imageSelector)
		}
	}

	executed, err := r.execute(ctx, hook, imageSelectors)
	if err != nil {
		return err
	} else if !executed {
		ctx.Log().Infof("Skip hook '%s', because no running containers were found", ansi.Color(hookName(hook), "white+b"))
	}

	return nil
}

func (r *remoteHook) execute(ctx devspacecontext.Context, hook *latest.HookConfig, imageSelector []imageselector.ImageSelector) (bool, error) {
	labelSelector := ""