From f22e02d2f1980544882d26126e8486979333aaf2 Mon Sep 17 00:00:00 2001 From: simon Date: Mon, 27 Sep 2021 10:38:57 +0700 Subject: [PATCH] hotfix to release leftover locks on restart --- tubearchivist/home/__init__.py | 11 ++++++++++- 1 file changed, 10 insertions(+), 1 deletion(-) diff --git a/tubearchivist/home/__init__.py b/tubearchivist/home/__init__.py index bc4b3d6..7b19ef5 100644 --- a/tubearchivist/home/__init__.py +++ b/tubearchivist/home/__init__.py @@ -3,7 +3,7 @@ import os from home.src.config import AppConfig -from home.src.helper import set_message +from home.src.helper import del_message, set_message from home.src.index_management import index_check from .tasks import app as celery_app @@ -36,7 +36,16 @@ def make_folders(): continue +def release_lock(): + """make sure there are no leftover locks set in redis on container start""" + all_locks = ["manual_import", "downloading"] + for lock in all_locks: + print("release leftover lock: " + lock) + del_message(lock) + + __all__ = ("celery_app",) make_folders() sync_redis_state() index_check() +release_lock()