minor fixes

2023-09-26 16:32:36 +03:00
parent df51b59379
commit 1d8b2e4a0d
3 changed files with 10 additions and 2 deletions
--- a/src/core/redis_client.py
+++ b/src/core/redis_client.py
@@ -60,3 +60,8 @@ class RedisClient:
        async with self.connection as connection:
            res = await connection.srem(self.TASKS_DONE_NAME + f":1", json.dumps(task, indent=4).encode('utf-8'))
        return res
+
+    async def del_tasks_queue(self) -> int:
+        async with self.connection as connection:
+            res = await connection.delete(self.TASKS_NAME + f":1")
+        return res