diff --git a/app/server/modules/agents/__tests__/agents-manager.events.test.ts b/app/server/modules/agents/__tests__/agents-manager.events.test.ts
index 8dde6e71..4d625b61 100644
--- a/app/server/modules/agents/__tests__/agents-manager.events.test.ts
+++ b/app/server/modules/agents/__tests__/agents-manager.events.test.ts
@@ -270,34 +270,6 @@ test("runBackup rejects before sending when the abort signal is already aborted"
 	await stopAgentController();
 });
 
-test("runBackup requests cancellation when the abort signal fires while sending", async () => {
-	resetAgentRuntime();
-	const abortController = new AbortController();
-	controllerMock.sendBackup.mockImplementation(() =>
-		Effect.sync(() => {
-			abortController.abort();
-			return true;
-		}),
-	);
-	controllerMock.cancelBackup.mockImplementation(() => Effect.succeed(false));
-	const { agentManager, startAgentController, stopAgentController } = await import("../agents-manager");
-
-	await startAgentController();
-	const result = await agentManager.runBackup("local", {
-		scheduleId: 42,
-		payload: backupPayload,
-		signal: abortController.signal,
-		onProgress: vi.fn(),
-	});
-
-	expect(result).toEqual({ status: "cancelled" });
-	expect(controllerMock.cancelBackup).toHaveBeenCalledWith("local", {
-		jobId: "job-1",
-		scheduleId: "schedule-1",
-	});
-	await stopAgentController();
-});
-
 test("restore events are delivered to the running restore callbacks", async () => {
 	resetAgentRuntime();
 	controllerMock.sendRestore.mockImplementation(() => Effect.succeed(true));
diff --git a/app/server/modules/agents/agents-manager.ts b/app/server/modules/agents/agents-manager.ts
index c039f3be..9a97996e 100644
--- a/app/server/modules/agents/agents-manager.ts
+++ b/app/server/modules/agents/agents-manager.ts
@@ -431,16 +431,8 @@ export const agentManager = {
 			});
 			getActiveBackupScheduleIdsByJobId().set(request.payload.jobId, request.scheduleId);
 		});
-		const cancelOnAbort = () => {
-			void requestBackupCancellation(agentId, request.scheduleId).catch((error) => {
-				logger.error(`Failed to cancel backup ${request.scheduleId} after abort: ${String(error)}`);
-			});
-		};
-		request.signal.addEventListener("abort", cancelOnAbort, { once: true });
-
 		try {
 			if (!(await Effect.runPromise(runtime.sendBackup(agentId, request.payload)))) {
-				request.signal.removeEventListener("abort", cancelOnAbort);
 				clearActiveBackupRun(request.scheduleId);
 				return {
 					status: "unavailable",
@@ -448,17 +440,10 @@ export const agentManager = {
 				} satisfies BackupExecutionResult;
 			}
 
-			if (request.signal.aborted) {
-				await requestBackupCancellation(agentId, request.scheduleId);
-			}
-
 			return await completion;
 		} catch (error) {
-			request.signal.removeEventListener("abort", cancelOnAbort);
 			clearActiveBackupRun(request.scheduleId);
 			throw error;
-		} finally {
-			request.signal.removeEventListener("abort", cancelOnAbort);
 		}
 	},
 	cancelBackup: async (agentId: string, scheduleId: number) => {
@@ -504,16 +489,8 @@ export const agentManager = {
 				cancellationRequested: false,
 			});
 		});
-		const cancelOnAbort = () => {
-			void requestRestoreCancellation(agentId, request.payload.restoreId).catch((error) => {
-				logger.error(`Failed to cancel restore ${request.payload.restoreId} after abort: ${String(error)}`);
-			});
-		};
-		request.signal.addEventListener("abort", cancelOnAbort, { once: true });
-
 		try {
 			if (!(await Effect.runPromise(runtime.sendRestore(agentId, request.payload)))) {
-				request.signal.removeEventListener("abort", cancelOnAbort);
 				clearActiveRestoreRun(request.payload.restoreId);
 				return {
 					status: "unavailable",
@@ -521,16 +498,11 @@ export const agentManager = {
 				};
 			}
 
-			if (request.signal.aborted) {
-				await requestRestoreCancellation(agentId, request.payload.restoreId);
-			}
-
 			return {
 				status: "started",
-				result: completion.finally(() => request.signal.removeEventListener("abort", cancelOnAbort)),
+				result: completion,
 			};
 		} catch (error) {
-			request.signal.removeEventListener("abort", cancelOnAbort);
 			clearActiveRestoreRun(request.payload.restoreId);
 			throw error;
 		}