From bbce2082e90655af1b22096b77017e1268bb9044 Mon Sep 17 00:00:00 2001 From: Cizz22 Date: Mon, 29 Dec 2025 22:13:42 +0700 Subject: [PATCH] fix --- temporal/activity.py | 5 +---- 1 file changed, 1 insertion(+), 4 deletions(-) diff --git a/temporal/activity.py b/temporal/activity.py index 6e29573..ebf8e5f 100644 --- a/temporal/activity.py +++ b/temporal/activity.py @@ -157,10 +157,7 @@ async def acquire_lock(job_id: str) -> dict: @activity.defn async def release_lock(job_id: str): - lock_owner = await redis_client.get(LOCK_KEY) - - if lock_owner == job_id: - await redis_client.delete(LOCK_KEY) + await redis_client.delete(LOCK_KEY) redis_client.hset( f"process:{job_id}",