diff --git a/core/cloudflow-cli/src/main/scala/akka/cli/cloudflow/Commands.scala b/core/cloudflow-cli/src/main/scala/akka/cli/cloudflow/Commands.scala index 6bfadc57c..d49db4bc4 100644 --- a/core/cloudflow-cli/src/main/scala/akka/cli/cloudflow/Commands.scala +++ b/core/cloudflow-cli/src/main/scala/akka/cli/cloudflow/Commands.scala @@ -78,7 +78,7 @@ object OptionsParser { private val operatorNamespace = { import scala.language.existentials - opt[String]('n', "operator-namespace") + opt[String]("operator-namespace") .text(s"the namespace where the operator is deployed") .action((ns, o) => { val cmd = o.command match { @@ -431,6 +431,7 @@ object commands { sealed trait Command[T] { val output: format.Format val namespace: Option[String] + val operatorNamespace: Option[String] def execution(kubeClient: => KubeClient, logger: CliLogger): Execution[T] diff --git a/core/cloudflow-cli/src/main/scala/akka/cli/cloudflow/execution/DeployExecution.scala b/core/cloudflow-cli/src/main/scala/akka/cli/cloudflow/execution/DeployExecution.scala index 56c2244fd..2cf6c879b 100644 --- a/core/cloudflow-cli/src/main/scala/akka/cli/cloudflow/execution/DeployExecution.scala +++ b/core/cloudflow-cli/src/main/scala/akka/cli/cloudflow/execution/DeployExecution.scala @@ -204,7 +204,7 @@ final case class DeployExecution(d: Deploy, client: KubeClient, logger: CliLogge if (d.noRegistryCredentials) Success(()) else { client.createImagePullSecret( - namespace = name, + namespace = namespace, dockerRegistryURL = image.registry.getOrElse(""), dockerUsername = d.dockerUsername, dockerPassword = d.dockerPassword)