diff --git a/tubearchivist/home/src/helper.py b/tubearchivist/home/src/helper.py index 423cde3..77c676d 100644 --- a/tubearchivist/home/src/helper.py +++ b/tubearchivist/home/src/helper.py @@ -104,7 +104,8 @@ def get_message(key): def del_message(key): """delete key from redis""" redis_connection = redis.Redis(host=REDIS_HOST) - redis_connection.execute_command("DEL", key) + response = redis_connection.execute_command("DEL", key) + return response def get_dl_message(cache_dir): diff --git a/tubearchivist/home/tasks.py b/tubearchivist/home/tasks.py index ce2c863..3a331f5 100644 --- a/tubearchivist/home/tasks.py +++ b/tubearchivist/home/tasks.py @@ -133,7 +133,7 @@ def run_restore_backup(): def kill_dl(task_id): """kill download worker task by ID""" app.control.revoke(task_id, terminate=True) - del_message("dl_queue_id") + _ = del_message("dl_queue_id") RedisQueue("dl_queue").clear() # clear cache