diff --git a/internal/armada/server/submit_to_log.go b/internal/armada/server/submit_to_log.go
index 859ab3a49ac..2e3524720bf 100644
--- a/internal/armada/server/submit_to_log.go
+++ b/internal/armada/server/submit_to_log.go
@@ -241,6 +241,7 @@ func (srv *PulsarSubmitServer) CancelJobs(ctx context.Context, req *api.JobCance
 		_, err := srv.CancelJobSet(ctx, &api.JobSetCancelRequest{
 			Queue:    req.Queue,
 			JobSetId: req.JobSetId,
+			Reason:   req.Reason,
 		})
 		if err != nil {
 			return nil, err
@@ -292,7 +293,7 @@ func (srv *PulsarSubmitServer) CancelJobs(ctx context.Context, req *api.JobCance
 			{
 				Created: pointer.Now(),
 				Event: &armadaevents.EventSequence_Event_CancelJob{
-					CancelJob: &armadaevents.CancelJob{JobId: jobId},
+					CancelJob: &armadaevents.CancelJob{JobId: jobId, Reason: req.Reason},
 				},
 			},
 		},