Allow controller flag to override restart policy (#1340)

pkg/kobject/kobject.go

@@ -78,6 +78,11 @@ type ConvertOptions struct {
 	WithKomposeAnnotation bool
 }
 
+// IsPodController indicate if the user want to use a controller
+func (opt *ConvertOptions) IsPodController() bool {
+	return opt.IsDeploymentFlag || opt.IsDaemonSetFlag || opt.IsReplicationControllerFlag || opt.Controller != ""
+}
+
 // ServiceConfig holds the basic struct of a container
 type ServiceConfig struct {
 	ContainerName     string

pkg/transformer/kubernetes/kubernetes.go

@@ -1154,11 +1154,8 @@ func (k *Kubernetes) Transform(komposeObject kobject.KomposeObject, opt kobject.
 		}
 
 		// Generate pod only and nothing more
-		if service.Restart == "no" || service.Restart == "on-failure" {
-			// Error out if Controller Object is specified with restart: 'on-failure'
-			if opt.IsDeploymentFlag || opt.IsDaemonSetFlag || opt.IsReplicationControllerFlag {
-				return nil, errors.New("Controller object cannot be specified with restart: 'on-failure'")
-			}
+		if (service.Restart == "no" || service.Restart == "on-failure") && !opt.IsPodController() {
+			log.Infof("Create kubernetes pod instead of pod controller due to restart policy: %s", service.Restart)
 			pod := k.InitPod(name, service)
 			objects = append(objects, pod)
 		} else {

pkg/transformer/kubernetes/kubernetes_test.go

@@ -518,8 +518,8 @@ func TestRestartOnFailure(t *testing.T) {
 		t.Log("Test case:", name)
 		k := Kubernetes{}
 		_, err := k.Transform(test.komposeObject, test.opt)
-		if err == nil {
-			t.Errorf("Expected an error, got %v instead", err)
+		if err != nil {
+			t.Errorf("Expected nil error, got %v instead", err)
 		}
 	}
 }