From 71c03e71ef973889cbc0f9c7f8bcc72388ad4674 Mon Sep 17 00:00:00 2001
From: itqop <leonkl32@gmail.com>
Date: Wed, 5 Nov 2025 02:38:54 +0300
Subject: [PATCH] fix: fixes

---
 src/dataloader/storage/repositories.py | 8 +++++---
 1 file changed, 5 insertions(+), 3 deletions(-)

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