Fix compaction task name

k8ssandra · Nov 13, 2023 · 97f9a79 · 97f9a79
1 parent 63da254
commit 97f9a79
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/pkg/tasks/create.go b/pkg/tasks/create.go
@@ -117,7 +117,7 @@ func CreateCompactionTask(ctx context.Context, kubeClient client.Client, dc *cas
 	if err != nil {
 		return nil, err
 	}
-	return CreateTask(ctx, kubeClient, controlapi.CommandRebuild, dc, args)
+	return CreateTask(ctx, kubeClient, controlapi.CommandCompaction, dc, args)
 }
 
 func compactionArguments(rackName, podName, keyspaceName string, tables []string) (*controlapi.JobArguments, error) {
@@ -142,7 +142,7 @@ func CreateClusterCompactionTask(ctx context.Context, kubeClient client.Client,
 	if err != nil {
 		return nil, err
 	}
-	return CreateClusterTask(ctx, kubeClient, controlapi.CommandRebuild, namespace, cluster, []string{dcName}, args)
+	return CreateClusterTask(ctx, kubeClient, controlapi.CommandCompaction, namespace, cluster, []string{dcName}, args)
 }
 
 // Move