diff --git a/controllers/conduit_containers.go b/controllers/conduit_containers.go
index 82bda10..bf2005b 100644
--- a/controllers/conduit_containers.go
+++ b/controllers/conduit_containers.go
@@ -134,11 +134,12 @@ func ConduitInitContainers(cc []*v1alpha.ConduitConnector) []corev1.Container {
 func ConduitRuntimeContainer(image, version string, envVars []corev1.EnvVar) corev1.Container {
 	args := []string{
 		"/app/conduit",
+		"run",
 		"-pipelines.path", v1alpha.ConduitPipelineFile,
 		"-connectors.path", v1alpha.ConduitConnectorsPath,
 		"-db.type", "sqlite",
 		"-db.sqlite.path", v1alpha.ConduitDBPath,
-		"-pipelines.exit-on-error",
+		"-pipelines.exit-on-degraded",
 		"-processors.path", v1alpha.ConduitProcessorsPath,
 	}
 
diff --git a/controllers/conduit_containers_test.go b/controllers/conduit_containers_test.go
index b4042f7..506c2dc 100644
--- a/controllers/conduit_containers_test.go
+++ b/controllers/conduit_containers_test.go
@@ -197,11 +197,12 @@ func Test_ConduitRuntimeContainer(t *testing.T) {
 		ImagePullPolicy: corev1.PullAlways,
 		Args: []string{
 			"/app/conduit",
+			"run",
 			"-pipelines.path", "/conduit.pipelines/pipeline.yaml",
 			"-connectors.path", "/conduit.storage/connectors",
 			"-db.type", "sqlite",
 			"-db.sqlite.path", "/conduit.storage/db",
-			"-pipelines.exit-on-error",
+			"-pipelines.exit-on-degraded",
 			"-processors.path",
 			"/conduit.storage/processors",
 		},