fix mkdir command

NearNodeFlash · Oct 3, 2024 · e3101b0 · e3101b0
1 parent 9e8f70b
commit e3101b0
Showing 1 changed file with 2 additions and 1 deletion.
diff --git a/internal/controller/datamovement_controller.go b/internal/controller/datamovement_controller.go
@@ -896,8 +896,9 @@ func createDestinationDir(profile *nnfv1alpha2.NnfDataMovementProfile, dm *nnfv1
 		return nil
 	}
 
+	// TODO mkdir command?
 	// Use setpriv to create the directory with the specified UID/GID
-	cmd := fmt.Sprintf("mpirun --hostfile %s -- setpriv --euid %d --egid %d --clear-groups mkdir -p %s",
+	cmd := fmt.Sprintf("mpirun --allow-run-as-root --hostfile %s -- setpriv --euid %d --egid %d --clear-groups mkdir -p %s",
 		mpiHostfile, dm.Spec.UserId, dm.Spec.GroupId, dest)
 	output, err := command.Run(cmd, log)
 	if err != nil {