diff --git a/api/ragflow_server.py b/api/ragflow_server.py
index d98f8a264..1b6775c06 100644
--- a/api/ragflow_server.py
+++ b/api/ragflow_server.py
@@ -61,8 +61,8 @@ def update_progress():
             stop_event.wait(6)
         except Exception:
             logging.exception("update_progress exception")
-            if redis_lock.acquired:
-                redis_lock.release()
+        finally:
+            redis_lock.release()
 
 def signal_handler(sig, frame):
     logging.info("Received interrupt signal, shutting down...")