diff --git a/pkg/commands/pipeline.go b/pkg/commands/pipeline.go
index ddd457b2..9d00c1f1 100644
--- a/pkg/commands/pipeline.go
+++ b/pkg/commands/pipeline.go
@@ -56,7 +56,7 @@ func addPipelineCordonAndDrainClusterCmd(toplevel *cobra.Command) {
 			}
 
 			if cliOpt.NodeGroupName == "" {
-				contextLogger.Fatal("--node-group-to-drain is required")
+				contextLogger.Fatal("--node-group is required")
 			}
 
 			pipeline.CordonAndDrainPipelineShellCmds(cliOpt.Name, cliOpt.NodeGroupName)
diff --git a/pkg/pipeline/pipeline.go b/pkg/pipeline/pipeline.go
index ed65bd16..8218f96e 100644
--- a/pkg/pipeline/pipeline.go
+++ b/pkg/pipeline/pipeline.go
@@ -27,7 +27,7 @@ func DeletePipelineShellCmds(clusterName string) {
 }
 
 func CordonAndDrainPipelineShellCmds(clusterName, nodeGroup string) {
-	strCmd := fmt.Sprintf("wget -qO- https://raw.githubusercontent.com/ministryofjustice/cloud-platform-terraform-concourse/main/pipelines/manager/main/cordon-and-drain.yaml | fly -t manager set-pipeline --pipeline cordon-and-drain-nodes  --config - -v node_group_to_drain=%s -v cluster_name=%s", nodeGroup, clusterName)
+	strCmd := fmt.Sprintf("wget -qO- https://raw.githubusercontent.com/ministryofjustice/cloud-platform-terraform-concourse/main/pipelines/manager/main/cordon-and-drain-nodes.yaml | fly -t manager set-pipeline --pipeline cordon-and-drain-nodes  --config - -v node_group_to_drain=%s -v cluster_name=%s", nodeGroup, clusterName)
 
 	runCmd("fly", []string{"--target", "manager", "login", "--team-name", "main", "--concourse-url", "https://concourse.cloud-platform.service.justice.gov.uk/"})
 	runCmd("bash", []string{"-c", strCmd})