Skip to content

Commit b0aa884

Browse files
committed
Remove result from Redis after reading
1 parent dd9b66e commit b0aa884

File tree

1 file changed

+6
-4
lines changed

1 file changed

+6
-4
lines changed

taskiq_redis/redis_backend.py

Lines changed: 6 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -75,10 +75,12 @@ async def get_result( # noqa: WPS210
7575
fields.remove("log")
7676

7777
async with Redis(connection_pool=self.redis_pool) as redis:
78-
result_values = await redis.hmget(
79-
name=task_id,
80-
keys=fields,
81-
)
78+
async with redis.pipeline() as pipe:
79+
result_values, _ = await (
80+
pipe.hmget(name=task_id, keys=fields)
81+
.delete(task_id)
82+
.execute()
83+
)
8284

8385
result = {
8486
result_key: pickle.loads(result_value)

0 commit comments

Comments
 (0)