fix killing task with missing task id

pull/57/head
simon 3 years ago
parent e202265a5f
commit 567e9d473b

@ -138,7 +138,9 @@ def run_restore_backup():
def kill_dl(task_id):
"""kill download worker task by ID"""
if task_id:
app.control.revoke(task_id, terminate=True)
_ = RedisArchivist().del_message("dl_queue_id")
RedisQueue("dl_queue").clear()

@ -588,6 +588,9 @@ class PostData:
RedisQueue("dl_queue").clear()
elif to_execute == "kill":
task_id = RedisArchivist().get_message("dl_queue_id")
if not task_id["status"]:
task_id = False
else:
print("brutally killing " + task_id)
kill_dl(task_id)

Loading…
Cancel
Save