INNER CODE UNIT · Go

importCmd

kubernetes-sigs/kueue · cmd/importer/main.go:204

func importCmd(cmd *cobra.Command, _ []string) error {
	log := ctrl.Log.WithName("import")
	ctx := ctrl.LoggerInto(context.Background(), log)
	cWorkers, _ := cmd.Flags().GetUint(ConcurrencyFlag)
	c, err := getKubeClient(cmd)
	if err != nil {
		return err
	}

	cache, err := loadMappingCache(ctx, c, cmd)
	if err != nil {
		return err
	}

	if err = pod.Check(ctx, c, cache, cWorkers); err != nil {
		return err
	}

View source record →