diff --git a/src/dataloader/storage/repositories.py b/src/dataloader/storage/repositories.py
index 2bd86be..01e22ca 100644
--- a/src/dataloader/storage/repositories.py
+++ b/src/dataloader/storage/repositories.py
@@ -187,9 +187,11 @@ class QueueRepository:
         """
         Устанавливает флаг отмены для задачи.
         """
-        q = update(DLJob).where(DLJob.job_id == job_id).values(cancel_requested=True)
-        await self.s.execute(q)
-        await self._append_event(job_id, await self._resolve_queue(job_id), "cancel_requested", None)
+        job = await self._get(job_id)
+        if not job:
+            return False
+        job.cancel_requested = True
+        await self._append_event(job_id, job.queue, "cancel_requested", None)
         await self.s.commit()
         return True