Release the lock after task execution.
(task_name, id)
| 303 | return lock_acquired |
| 304 | |
| 305 | def release_task_lock(task_name, id): |
| 306 | """Release the lock after task execution.""" |
| 307 | redis_client = RedisClient.get_client() |
| 308 | lock_id = f"task_lock_{task_name}_{id}" |
| 309 | |
| 310 | # Remove the lock |
| 311 | redis_client.delete(lock_id) |
| 312 | |
| 313 | |
| 314 | def is_task_lock_held(task_name, id): |