We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent dd9b66e commit b0aa884Copy full SHA for b0aa884
taskiq_redis/redis_backend.py
@@ -75,10 +75,12 @@ async def get_result( # noqa: WPS210
75
fields.remove("log")
76
77
async with Redis(connection_pool=self.redis_pool) as redis:
78
- result_values = await redis.hmget(
79
- name=task_id,
80
- keys=fields,
81
- )
+ async with redis.pipeline() as pipe:
+ result_values, _ = await (
+ pipe.hmget(name=task_id, keys=fields)
+ .delete(task_id)
82
+ .execute()
83
+ )
84
85
result = {
86
result_key: pickle.loads(result_value)
0 commit comments