fix

2 weeks ago · bbce2082e9
parent 6deb8749b0
commit bbce2082e9
1 changed files with 1 additions and 4 deletions
--- 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)
+    await redis_client.delete(LOCK_KEY)
    if lock_owner == job_id:
        await redis_client.delete(LOCK_KEY)
    redis_client.hset(
        f"process:{job_id}",