Make external builder helpers

soltysh · soltysh · commit 7240c760ae21 · 2018-08-16T14:29:10.000+02:00
diff --git a/pkg/build/apis/build/v1/conversion.go b/pkg/build/apis/build/v1/conversion.go
@@ -19,7 +19,7 @@ func Convert_v1_BuildConfig_To_build_BuildConfig(in *v1.BuildConfig, out *newer.
 	// Strip off any default imagechange triggers where the buildconfig's
 	// "from" is not an ImageStreamTag, because those triggers
 	// will never be invoked.
-	imageRef := buildapihelpers.GetInputReference(out.Spec.Strategy)
+	imageRef := buildapihelpers.GetInputReferenceInternal(out.Spec.Strategy)
 	hasIST := imageRef != nil && imageRef.Kind == "ImageStreamTag"
 	for _, trigger := range out.Spec.Triggers {
 		if trigger.Type != newer.ImageChangeBuildTriggerType {
diff --git a/pkg/build/apis/build/validation/validation.go b/pkg/build/apis/build/validation/validation.go
@@ -42,7 +42,7 @@ func ValidateBuildUpdate(build *buildapi.Build, older *buildapi.Build) field.Err
 	allErrs = append(allErrs, validation.ValidateObjectMetaUpdate(&build.ObjectMeta, &older.ObjectMeta, field.NewPath("metadata"))...)
 	allErrs = append(allErrs, validation.ValidateObjectMeta(&build.ObjectMeta, true, validation.NameIsDNSSubdomain, field.NewPath("metadata"))...)
 
-	if buildutil.IsBuildComplete(older) && older.Status.Phase != build.Status.Phase {
+	if buildutil.IsBuildCompleteInternal(older) && older.Status.Phase != build.Status.Phase {
 		allErrs = append(allErrs, field.Invalid(field.NewPath("status", "phase"), build.Status.Phase, "phase cannot be updated from a terminal state"))
 	}
 
@@ -85,7 +85,7 @@ func ValidateBuildConfig(config *buildapi.BuildConfig) field.ErrorList {
 	fromRefs := map[string]struct{}{}
 	specPath := field.NewPath("spec")
 	triggersPath := specPath.Child("triggers")
-	buildFrom := buildapihelpers.GetInputReference(config.Spec.Strategy)
+	buildFrom := buildapihelpers.GetInputReferenceInternal(config.Spec.Strategy)
 	for i, trg := range config.Spec.Triggers {
 		allErrs = append(allErrs, validateTrigger(&trg, buildFrom, triggersPath.Index(i))...)
 		if trg.Type != buildapi.ImageChangeBuildTriggerType || trg.ImageChange == nil {
diff --git a/pkg/build/apiserver/registry/build/strategy.go b/pkg/build/apiserver/registry/build/strategy.go
@@ -97,7 +97,7 @@ func (detailsStrategy) PrepareForUpdate(ctx context.Context, obj, old runtime.Ob
 	// a completed phase.
 	phase := oldBuild.Status.Phase
 	stages := newBuild.Status.Stages
-	if buildutil.IsBuildComplete(newBuild) {
+	if buildutil.IsBuildCompleteInternal(newBuild) {
 		phase = newBuild.Status.Phase
 	}
 	revision := newBuild.Spec.Revision
diff --git a/pkg/build/buildapihelpers/helpers.go b/pkg/build/buildapihelpers/helpers.go
@@ -1,8 +1,10 @@
 package buildapihelpers
 
 import (
+	corev1 "k8s.io/api/core/v1"
 	coreinternalapi "k8s.io/kubernetes/pkg/apis/core"
 
+	buildv1 "github.com/openshift/api/build/v1"
 	buildinternalapi "github.com/openshift/origin/pkg/build/apis/build"
 )
 
@@ -36,9 +38,24 @@ func HasTriggerType(triggerType buildinternalapi.BuildTriggerType, bc *buildinte
 	return len(matches) > 0
 }
 
+// GetInputReferenceInternal returns the From ObjectReference associated with the
+// BuildStrategy.
+func GetInputReferenceInternal(strategy buildinternalapi.BuildStrategy) *coreinternalapi.ObjectReference {
+	switch {
+	case strategy.SourceStrategy != nil:
+		return &strategy.SourceStrategy.From
+	case strategy.DockerStrategy != nil:
+		return strategy.DockerStrategy.From
+	case strategy.CustomStrategy != nil:
+		return &strategy.CustomStrategy.From
+	default:
+		return nil
+	}
+}
+
 // GetInputReference returns the From ObjectReference associated with the
 // BuildStrategy.
-func GetInputReference(strategy buildinternalapi.BuildStrategy) *coreinternalapi.ObjectReference {
+func GetInputReference(strategy buildv1.BuildStrategy) *corev1.ObjectReference {
 	switch {
 	case strategy.SourceStrategy != nil:
 		return &strategy.SourceStrategy.From
diff --git a/pkg/build/controller/build/build_controller.go b/pkg/build/controller/build/build_controller.go
@@ -330,7 +330,7 @@ func (bc *BuildController) handleBuild(build *buildapi.Build) error {
 
 	// If pipeline build, handle pruning.
 	if build.Spec.Strategy.JenkinsPipelineStrategy != nil {
-		if buildutil.IsBuildComplete(build) {
+		if buildutil.IsBuildCompleteInternal(build) {
 			if err := common.HandleBuildPruning(buildutil.ConfigNameForBuild(build), build.Namespace, bc.buildLister, bc.buildConfigGetter, bc.buildDeleter); err != nil {
 				utilruntime.HandleError(fmt.Errorf("failed to prune builds for %s/%s: %v", build.Namespace, build.Name, err))
 			}
@@ -363,7 +363,7 @@ func (bc *BuildController) handleBuild(build *buildapi.Build) error {
 	case build.Status.Phase == buildapi.BuildPhasePending,
 		build.Status.Phase == buildapi.BuildPhaseRunning:
 		update, err = bc.handleActiveBuild(build, pod)
-	case buildutil.IsBuildComplete(build):
+	case buildutil.IsBuildCompleteInternal(build):
 		update, err = bc.handleCompletedBuild(build, pod)
 	}
 	if update != nil && !update.isEmpty() {
@@ -395,7 +395,7 @@ func shouldIgnore(build *buildapi.Build) bool {
 	// state and its completion time or logsnippet is not set, then we should at least attempt to set its
 	// completion time and logsnippet if possible because the build pod may have put the build in
 	// this state and it would have not set the completion timestamp or logsnippet data.
-	if buildutil.IsBuildComplete(build) {
+	if buildutil.IsBuildCompleteInternal(build) {
 		switch build.Status.Phase {
 		case buildapi.BuildPhaseComplete:
 			if build.Status.CompletionTimestamp == nil {
@@ -415,7 +415,7 @@ func shouldIgnore(build *buildapi.Build) bool {
 
 // shouldCancel returns true if a build is active and its cancellation flag is set
 func shouldCancel(build *buildapi.Build) bool {
-	return !buildutil.IsBuildComplete(build) && build.Status.Cancelled
+	return !buildutil.IsBuildCompleteInternal(build) && build.Status.Cancelled
 }
 
 // cancelBuild deletes a build pod and returns an update to mark the build as cancelled
@@ -1085,7 +1085,7 @@ func (bc *BuildController) updateBuild(build *buildapi.Build, update *buildUpdat
 		}
 
 		// Update build completion timestamp if transitioning to a terminal phase
-		if buildutil.IsTerminalPhase(*update.phase) {
+		if buildutil.IsTerminalPhaseInternal(*update.phase) {
 			setBuildCompletionData(build, pod, update)
 		}
 		glog.V(4).Infof("Updating build %s -> %s%s", buildDesc(build), *update.phase, reasonText)
@@ -1114,7 +1114,7 @@ func (bc *BuildController) updateBuild(build *buildapi.Build, update *buildUpdat
 			buildapi.BuildPhaseFailed:
 			bc.recorder.Eventf(patchedBuild, kapi.EventTypeNormal, buildapi.BuildFailedEventReason, fmt.Sprintf(buildapi.BuildFailedEventMessage, patchedBuild.Namespace, patchedBuild.Name))
 		}
-		if buildutil.IsTerminalPhase(*update.phase) {
+		if buildutil.IsTerminalPhaseInternal(*update.phase) {
 			bc.handleBuildCompletion(patchedBuild)
 		}
 	}
@@ -1270,7 +1270,7 @@ func (bc *BuildController) buildDeleted(obj interface{}) {
 		}
 	}
 	// If the build was not in a complete state, poke the buildconfig to run the next build
-	if !buildutil.IsBuildComplete(build) {
+	if !buildutil.IsBuildCompleteInternal(build) {
 		bcName := buildutil.ConfigNameForBuild(build)
 		bc.enqueueBuildConfig(build.Namespace, bcName)
 	}
@@ -1375,7 +1375,7 @@ func isValidTransition(from, to buildapi.BuildPhase) bool {
 	}
 
 	switch {
-	case buildutil.IsTerminalPhase(from):
+	case buildutil.IsTerminalPhaseInternal(from):
 		return false
 	case from == buildapi.BuildPhasePending:
 		switch to {
diff --git a/pkg/build/controller/build/build_controller_test.go b/pkg/build/controller/build/build_controller_test.go
@@ -758,7 +758,7 @@ func TestIsValidTransition(t *testing.T) {
 	}
 	for _, fromPhase := range phases {
 		for _, toPhase := range phases {
-			if buildutil.IsTerminalPhase(fromPhase) && fromPhase != toPhase {
+			if buildutil.IsTerminalPhaseInternal(fromPhase) && fromPhase != toPhase {
 				if isValidTransition(fromPhase, toPhase) {
 					t.Errorf("transition %v -> %v should be invalid", fromPhase, toPhase)
 				}
@@ -795,7 +795,7 @@ func TestIsTerminal(t *testing.T) {
 		buildapi.BuildPhaseCancelled: true,
 	}
 	for phase, expected := range tests {
-		if actual := buildutil.IsTerminalPhase(phase); actual != expected {
+		if actual := buildutil.IsTerminalPhaseInternal(phase); actual != expected {
 			t.Errorf("unexpected response for %s: %v", phase, actual)
 		}
 	}
diff --git a/pkg/build/controller/policy/serial_latest_only.go b/pkg/build/controller/policy/serial_latest_only.go
@@ -64,7 +64,7 @@ func (s *SerialLatestOnlyPolicy) cancelPreviousBuilds(build *buildapi.Build) []e
 	builds, err := buildutil.BuildConfigBuilds(s.BuildLister, build.Namespace, bcName, func(b *buildapi.Build) bool {
 		// Do not cancel the complete builds, builds that were already cancelled, or
 		// running builds.
-		if buildutil.IsBuildComplete(b) || b.Status.Phase == buildapi.BuildPhaseRunning {
+		if buildutil.IsBuildCompleteInternal(b) || b.Status.Phase == buildapi.BuildPhaseRunning {
 			return false
 		}
 
diff --git a/pkg/build/generator/generator.go b/pkg/build/generator/generator.go
@@ -154,7 +154,7 @@ func findImageChangeTrigger(bc *buildapi.BuildConfig, ref *kapi.ObjectReference)
 		imageChange := trigger.ImageChange
 		triggerRef := imageChange.From
 		if triggerRef == nil {
-			triggerRef = buildapihelpers.GetInputReference(bc.Spec.Strategy)
+			triggerRef = buildapihelpers.GetInputReferenceInternal(bc.Spec.Strategy)
 			if triggerRef == nil || triggerRef.Kind != "ImageStreamTag" {
 				continue
 			}
@@ -356,7 +356,7 @@ func (g *BuildGenerator) updateImageTriggers(ctx context.Context, bc *buildapi.B
 
 		triggerImageRef := trigger.ImageChange.From
 		if triggerImageRef == nil {
-			triggerImageRef = buildapihelpers.GetInputReference(bc.Spec.Strategy)
+			triggerImageRef = buildapihelpers.GetInputReferenceInternal(bc.Spec.Strategy)
 		}
 		if triggerImageRef == nil {
 			glog.Warningf("Could not get ImageStream reference for default ImageChangeTrigger on BuildConfig %s/%s", bc.Namespace, bc.Name)
@@ -541,7 +541,7 @@ func (g *BuildGenerator) setBuildSourceImage(ctx context.Context, builderSecrets
 		var sourceImageSpec string
 		// if the imagesource matches the strategy from, and we have a trigger for the strategy from,
 		// use the imageid from the trigger rather than resolving it.
-		if strategyFrom := buildapihelpers.GetInputReference(bcCopy.Spec.Strategy); strategyFrom != nil &&
+		if strategyFrom := buildapihelpers.GetInputReferenceInternal(bcCopy.Spec.Strategy); strategyFrom != nil &&
 			reflect.DeepEqual(sourceImage.From, *strategyFrom) &&
 			strategyImageChangeTrigger != nil {
 			sourceImageSpec = strategyImageChangeTrigger.LastTriggeredImageID
diff --git a/pkg/build/generator/generator_test.go b/pkg/build/generator/generator_test.go
@@ -449,7 +449,7 @@ func TestInstantiateWithImageTrigger(t *testing.T) {
 			if bc.Spec.Triggers[i].Type == buildapi.ImageChangeBuildTriggerType {
 				from := bc.Spec.Triggers[i].ImageChange.From
 				if from == nil {
-					from = buildapihelpers.GetInputReference(bc.Spec.Strategy)
+					from = buildapihelpers.GetInputReferenceInternal(bc.Spec.Strategy)
 				}
 				if bc.Spec.Triggers[i].ImageChange.LastTriggeredImageID != ("ref/" + from.Name) {
 					t.Errorf("%s: expected LastTriggeredImageID for trigger at %d (%+v) to be %s. Got: %s", tc.name, i, bc.Spec.Triggers[i].ImageChange.From, "ref/"+from.Name, bc.Spec.Triggers[i].ImageChange.LastTriggeredImageID)
diff --git a/pkg/build/util/util.go b/pkg/build/util/util.go
@@ -16,6 +16,7 @@ import (
 	"k8s.io/kubernetes/pkg/credentialprovider"
 	credentialprovidersecrets "k8s.io/kubernetes/pkg/credentialprovider/secrets"
 
+	buildv1 "github.com/openshift/api/build/v1"
 	buildapi "github.com/openshift/origin/pkg/build/apis/build"
 	"github.com/openshift/origin/pkg/build/buildapihelpers"
 	buildlister "github.com/openshift/origin/pkg/build/generated/listers/build/internalversion"
@@ -39,13 +40,13 @@ var (
 	proxyRegex       = regexp.MustCompile("(?i)proxy")
 )
 
-// IsBuildComplete returns whether the provided build is complete or not
-func IsBuildComplete(build *buildapi.Build) bool {
-	return IsTerminalPhase(build.Status.Phase)
+// IsBuildCompleteInternal returns whether the provided build is complete or not
+func IsBuildCompleteInternal(build *buildapi.Build) bool {
+	return IsTerminalPhaseInternal(build.Status.Phase)
 }
 
 // IsTerminalPhase returns true if the provided phase is terminal
-func IsTerminalPhase(phase buildapi.BuildPhase) bool {
+func IsTerminalPhaseInternal(phase buildapi.BuildPhase) bool {
 	switch phase {
 	case buildapi.BuildPhaseNew,
 		buildapi.BuildPhasePending,
@@ -55,6 +56,22 @@ func IsTerminalPhase(phase buildapi.BuildPhase) bool {
 	return true
 }
 
+// IsBuildComplete returns whether the provided build is complete or not
+func IsBuildComplete(build *buildv1.Build) bool {
+	return IsTerminalPhase(build.Status.Phase)
+}
+
+// IsTerminalPhase returns true if the provided phase is terminal
+func IsTerminalPhase(phase buildv1.BuildPhase) bool {
+	switch phase {
+	case buildv1.BuildPhaseNew,
+		buildv1.BuildPhasePending,
+		buildv1.BuildPhaseRunning:
+		return false
+	}
+	return true
+}
+
 // BuildNameForConfigVersion returns the name of the version-th build
 // for the config that has the provided name.
 func BuildNameForConfigVersion(name string, version int) string {
diff --git a/pkg/image/controller/trigger/image_trigger_controller_test.go b/pkg/image/controller/trigger/image_trigger_controller_test.go
@@ -948,7 +948,7 @@ func updateBuildConfigImages(bc *buildapi.BuildConfig, tagRetriever trigger.TagR
 		if p.From != nil {
 			from = p.From
 		} else {
-			from = buildapihelpers.GetInputReference(bc.Spec.Strategy)
+			from = buildapihelpers.GetInputReferenceInternal(bc.Spec.Strategy)
 		}
 		namespace := from.Namespace
 		if len(namespace) == 0 {
diff --git a/pkg/image/trigger/buildconfigs/buildconfigs.go b/pkg/image/trigger/buildconfigs/buildconfigs.go
@@ -38,7 +38,7 @@ func calculateBuildConfigTriggers(bc *buildapi.BuildConfig) []triggerapi.ObjectF
 			from = t.ImageChange.From
 			fieldPath = "spec.triggers"
 		} else {
-			from = buildapihelpers.GetInputReference(bc.Spec.Strategy)
+			from = buildapihelpers.GetInputReferenceInternal(bc.Spec.Strategy)
 			fieldPath = "spec.strategy.*.from"
 		}
 		if from == nil || from.Kind != "ImageStreamTag" || len(from.Name) == 0 {
@@ -152,7 +152,7 @@ func (r *buildConfigReactor) ImageChanged(obj runtime.Object, tagRetriever trigg
 		if p.From != nil {
 			from = p.From
 		} else {
-			from = buildapihelpers.GetInputReference(bc.Spec.Strategy)
+			from = buildapihelpers.GetInputReferenceInternal(bc.Spec.Strategy)
 		}
 		namespace := from.Namespace
 		if len(namespace) == 0 {
diff --git a/pkg/oc/cli/cancelbuild/cancelbuild.go b/pkg/oc/cli/cancelbuild/cancelbuild.go
@@ -20,8 +20,6 @@ import (
 	"github.com/openshift/api/build"
 	buildv1 "github.com/openshift/api/build/v1"
 	buildtv1client "github.com/openshift/client-go/build/clientset/versioned/typed/build/v1"
-	buildapi "github.com/openshift/origin/pkg/build/apis/build"
-	buildapiv1 "github.com/openshift/origin/pkg/build/apis/build/v1"
 	buildclientinternal "github.com/openshift/origin/pkg/build/client"
 	buildclientv1 "github.com/openshift/origin/pkg/build/client/v1"
 	buildinternalclient "github.com/openshift/origin/pkg/build/generated/internalclientset"
@@ -212,12 +210,7 @@ func (o *CancelBuildOptions) RunCancelBuild() error {
 			}
 		}
 
-		internalBuildStatus := &buildapi.BuildStatus{}
-		if err := buildapiv1.Convert_v1_BuildStatus_To_build_BuildStatus(&build.Status, internalBuildStatus, nil); err != nil {
-			return err
-		}
-
-		if stateMatch && !buildutil.IsTerminalPhase(internalBuildStatus.Phase) {
+		if stateMatch && !buildutil.IsTerminalPhase(build.Phase) {
 			builds = append(builds, build)
 		}
 	}
diff --git a/pkg/oc/lib/newapp/cmd/newapp.go b/pkg/oc/lib/newapp/cmd/newapp.go
@@ -1192,7 +1192,7 @@ func (c *AppConfig) checkCircularReferences(objects app.Objects) error {
 		}
 
 		if bc, ok := obj.(*buildapi.BuildConfig); ok {
-			input := buildapihelpers.GetInputReference(bc.Spec.Strategy)
+			input := buildapihelpers.GetInputReferenceInternal(bc.Spec.Strategy)
 			output := bc.Spec.Output.To
 
 			if output == nil || input == nil {
diff --git a/pkg/template/controller/readiness.go b/pkg/template/controller/readiness.go
@@ -29,10 +29,10 @@ import (
 func checkBuildReadiness(obj runtime.Object) (bool, bool, error) {
 	b := obj.(*buildapi.Build)
 
-	ready := buildutil.IsTerminalPhase(b.Status.Phase) &&
+	ready := buildutil.IsTerminalPhaseInternal(b.Status.Phase) &&
 		b.Status.Phase == buildapi.BuildPhaseComplete
 
-	failed := buildutil.IsTerminalPhase(b.Status.Phase) &&
+	failed := buildutil.IsTerminalPhaseInternal(b.Status.Phase) &&
 		b.Status.Phase != buildapi.BuildPhaseComplete
 
 	return ready, failed, nil
diff --git a/test/extended/builds/run_policy.go b/test/extended/builds/run_policy.go
@@ -73,7 +73,7 @@ var _ = g.Describe("[Feature:Builds][Slow] using build configuration runPolicy",
 				for {
 					event := <-buildWatch.ResultChan()
 					build := event.Object.(*buildapi.Build)
-					o.Expect(buildutil.IsBuildComplete(build)).Should(o.BeFalse())
+					o.Expect(buildutil.IsBuildCompleteInternal(build)).Should(o.BeFalse())
 					if build.Name == startedBuilds[0] && build.Status.Phase == buildapi.BuildPhaseRunning {
 						break
 					}
@@ -92,7 +92,7 @@ var _ = g.Describe("[Feature:Builds][Slow] using build configuration runPolicy",
 					event := <-buildWatch.ResultChan()
 					build := event.Object.(*buildapi.Build)
 					if build.Name == startedBuilds[0] {
-						if buildutil.IsBuildComplete(build) {
+						if buildutil.IsBuildCompleteInternal(build) {
 							break
 						}
 						continue
@@ -117,7 +117,7 @@ var _ = g.Describe("[Feature:Builds][Slow] using build configuration runPolicy",
 						counter++
 					}
 					// When the build failed or completed prematurely, fail the test
-					o.Expect(buildutil.IsBuildComplete(build)).Should(o.BeFalse())
+					o.Expect(buildutil.IsBuildCompleteInternal(build)).Should(o.BeFalse())
 					if counter == 2 {
 						break
 					}
@@ -403,7 +403,7 @@ var _ = g.Describe("[Feature:Builds][Slow] using build configuration runPolicy",
 							expectedRunningBuild = 2
 							break
 						}
-						o.Expect(buildutil.IsBuildComplete(build)).Should(o.BeFalse())
+						o.Expect(buildutil.IsBuildCompleteInternal(build)).Should(o.BeFalse())
 					}
 				}
 

Original file line number	Diff line number	Diff line change
`@@ -97,7 +97,7 @@ func (detailsStrategy) PrepareForUpdate(ctx context.Context, obj, old runtime.Ob`
`97`	`97`	`// a completed phase.`
`98`	`98`	`phase := oldBuild.Status.Phase`
`99`	`99`	`stages := newBuild.Status.Stages`
`100`		`- if buildutil.IsBuildComplete(newBuild) {`
	`100`	`+ if buildutil.IsBuildCompleteInternal(newBuild) {`
`101`	`101`	`phase = newBuild.Status.Phase`
`102`	`102`	`}`
`103`	`103`	`revision := newBuild.Spec.Revision`
Original file line number	Diff line number	Diff line change
`@@ -330,7 +330,7 @@ func (bc BuildController) handleBuild(build buildapi.Build) error {`
`330`	`330`
`331`	`331`	`// If pipeline build, handle pruning.`
`332`	`332`	`if build.Spec.Strategy.JenkinsPipelineStrategy != nil {`
`333`		`- if buildutil.IsBuildComplete(build) {`
	`333`	`+ if buildutil.IsBuildCompleteInternal(build) {`
`334`	`334`	`if err := common.HandleBuildPruning(buildutil.ConfigNameForBuild(build), build.Namespace, bc.buildLister, bc.buildConfigGetter, bc.buildDeleter); err != nil {`
`335`	`335`	`utilruntime.HandleError(fmt.Errorf("failed to prune builds for %s/%s: %v", build.Namespace, build.Name, err))`
`336`	`336`	`}`
`@@ -363,7 +363,7 @@ func (bc BuildController) handleBuild(build buildapi.Build) error {`
`363`	`363`	`case build.Status.Phase == buildapi.BuildPhasePending,`
`364`	`364`	`build.Status.Phase == buildapi.BuildPhaseRunning:`
`365`	`365`	`update, err = bc.handleActiveBuild(build, pod)`
`366`		`- case buildutil.IsBuildComplete(build):`
	`366`	`+ case buildutil.IsBuildCompleteInternal(build):`
`367`	`367`	`update, err = bc.handleCompletedBuild(build, pod)`
`368`	`368`	`}`
`369`	`369`	`if update != nil && !update.isEmpty() {`
`@@ -395,7 +395,7 @@ func shouldIgnore(build *buildapi.Build) bool {`
`395`	`395`	`// state and its completion time or logsnippet is not set, then we should at least attempt to set its`
`396`	`396`	`// completion time and logsnippet if possible because the build pod may have put the build in`
`397`	`397`	`// this state and it would have not set the completion timestamp or logsnippet data.`
`398`		`- if buildutil.IsBuildComplete(build) {`
	`398`	`+ if buildutil.IsBuildCompleteInternal(build) {`
`399`	`399`	`switch build.Status.Phase {`
`400`	`400`	`case buildapi.BuildPhaseComplete:`
`401`	`401`	`if build.Status.CompletionTimestamp == nil {`
`@@ -415,7 +415,7 @@ func shouldIgnore(build *buildapi.Build) bool {`
`415`	`415`
`416`	`416`	`// shouldCancel returns true if a build is active and its cancellation flag is set`
`417`	`417`	`func shouldCancel(build *buildapi.Build) bool {`
`418`		`- return !buildutil.IsBuildComplete(build) && build.Status.Cancelled`
	`418`	`+ return !buildutil.IsBuildCompleteInternal(build) && build.Status.Cancelled`
`419`	`419`	`}`
`420`	`420`
`421`	`421`	`// cancelBuild deletes a build pod and returns an update to mark the build as cancelled`
`@@ -1085,7 +1085,7 @@ func (bc BuildController) updateBuild(build buildapi.Build, update *buildUpdat`
`1085`	`1085`	`}`
`1086`	`1086`
`1087`	`1087`	`// Update build completion timestamp if transitioning to a terminal phase`
`1088`		`- if buildutil.IsTerminalPhase(*update.phase) {`
	`1088`	`+ if buildutil.IsTerminalPhaseInternal(*update.phase) {`
`1089`	`1089`	`setBuildCompletionData(build, pod, update)`
`1090`	`1090`	`}`
`1091`	`1091`	`glog.V(4).Infof("Updating build %s -> %s%s", buildDesc(build), *update.phase, reasonText)`
`@@ -1114,7 +1114,7 @@ func (bc BuildController) updateBuild(build buildapi.Build, update *buildUpdat`
`1114`	`1114`	`buildapi.BuildPhaseFailed:`
`1115`	`1115`	`bc.recorder.Eventf(patchedBuild, kapi.EventTypeNormal, buildapi.BuildFailedEventReason, fmt.Sprintf(buildapi.BuildFailedEventMessage, patchedBuild.Namespace, patchedBuild.Name))`
`1116`	`1116`	`}`
`1117`		`- if buildutil.IsTerminalPhase(*update.phase) {`
	`1117`	`+ if buildutil.IsTerminalPhaseInternal(*update.phase) {`
`1118`	`1118`	`bc.handleBuildCompletion(patchedBuild)`
`1119`	`1119`	`}`
`1120`	`1120`	`}`
`@@ -1270,7 +1270,7 @@ func (bc *BuildController) buildDeleted(obj interface{}) {`
`1270`	`1270`	`}`
`1271`	`1271`	`}`
`1272`	`1272`	`// If the build was not in a complete state, poke the buildconfig to run the next build`
`1273`		`- if !buildutil.IsBuildComplete(build) {`
	`1273`	`+ if !buildutil.IsBuildCompleteInternal(build) {`
`1274`	`1274`	`bcName := buildutil.ConfigNameForBuild(build)`
`1275`	`1275`	`bc.enqueueBuildConfig(build.Namespace, bcName)`
`1276`	`1276`	`}`
`@@ -1375,7 +1375,7 @@ func isValidTransition(from, to buildapi.BuildPhase) bool {`
`1375`	`1375`	`}`
`1376`	`1376`
`1377`	`1377`	`switch {`
`1378`		`- case buildutil.IsTerminalPhase(from):`
	`1378`	`+ case buildutil.IsTerminalPhaseInternal(from):`
`1379`	`1379`	`return false`
`1380`	`1380`	`case from == buildapi.BuildPhasePending:`
`1381`	`1381`	`switch to {`
Original file line number	Diff line number	Diff line change
`@@ -758,7 +758,7 @@ func TestIsValidTransition(t *testing.T) {`
`758`	`758`	`}`
`759`	`759`	`for _, fromPhase := range phases {`
`760`	`760`	`for _, toPhase := range phases {`
`761`		`- if buildutil.IsTerminalPhase(fromPhase) && fromPhase != toPhase {`
	`761`	`+ if buildutil.IsTerminalPhaseInternal(fromPhase) && fromPhase != toPhase {`
`762`	`762`	`if isValidTransition(fromPhase, toPhase) {`
`763`	`763`	`t.Errorf("transition %v -> %v should be invalid", fromPhase, toPhase)`
`764`	`764`	`}`
`@@ -795,7 +795,7 @@ func TestIsTerminal(t *testing.T) {`
`795`	`795`	`buildapi.BuildPhaseCancelled: true,`
`796`	`796`	`}`
`797`	`797`	`for phase, expected := range tests {`
`798`		`- if actual := buildutil.IsTerminalPhase(phase); actual != expected {`
	`798`	`+ if actual := buildutil.IsTerminalPhaseInternal(phase); actual != expected {`
`799`	`799`	`t.Errorf("unexpected response for %s: %v", phase, actual)`
`800`	`800`	`}`
`801`	`801`	`}`
Original file line number	Diff line number	Diff line change
`@@ -64,7 +64,7 @@ func (s SerialLatestOnlyPolicy) cancelPreviousBuilds(build buildapi.Build) []e`
`64`	`64`	`builds, err := buildutil.BuildConfigBuilds(s.BuildLister, build.Namespace, bcName, func(b *buildapi.Build) bool {`
`65`	`65`	`// Do not cancel the complete builds, builds that were already cancelled, or`
`66`	`66`	`// running builds.`
`67`		`- if buildutil.IsBuildComplete(b) \|\| b.Status.Phase == buildapi.BuildPhaseRunning {`
	`67`	`+ if buildutil.IsBuildCompleteInternal(b) \|\| b.Status.Phase == buildapi.BuildPhaseRunning {`
`68`	`68`	`return false`
`69`	`69`	`}`
`70`	`70`
Original file line number	Diff line number	Diff line change
`@@ -449,7 +449,7 @@ func TestInstantiateWithImageTrigger(t *testing.T) {`
`449`	`449`	`if bc.Spec.Triggers[i].Type == buildapi.ImageChangeBuildTriggerType {`
`450`	`450`	`from := bc.Spec.Triggers[i].ImageChange.From`
`451`	`451`	`if from == nil {`
`452`		`- from = buildapihelpers.GetInputReference(bc.Spec.Strategy)`
	`452`	`+ from = buildapihelpers.GetInputReferenceInternal(bc.Spec.Strategy)`
`453`	`453`	`}`
`454`	`454`	`if bc.Spec.Triggers[i].ImageChange.LastTriggeredImageID != ("ref/" + from.Name) {`
`455`	`455`	`t.Errorf("%s: expected LastTriggeredImageID for trigger at %d (%+v) to be %s. Got: %s", tc.name, i, bc.Spec.Triggers[i].ImageChange.From, "ref/"+from.Name, bc.Spec.Triggers[i].ImageChange.LastTriggeredImageID)`