diff --git a/omv_backup.py b/omv_backup.py index a6d007d..f2b97f3 100755 --- a/omv_backup.py +++ b/omv_backup.py @@ -666,6 +666,7 @@ def backup_job(server): logging.info(msg) send_mqtt_message(topic,msg) + continue if is_port_open(s,22): ssh = paramiko.SSHClient() ssh.load_system_host_keys() @@ -694,8 +695,8 @@ def backup_job(server): except: pass - message= "finished1" - client.publish(topic, message,qos=2,retain=True) + return "finished1" + if _RESTORE: restore_job() @@ -745,7 +746,8 @@ def handle_payload(payload): payload = payload.lower() if payload == 'm-server': logging.info("💡 Starting backup job") - backup_job(payload) + res = backup_job(payload) + client.publish(topic, res,qos=2,retain=True) else: logging.error(f"⚠️ Unknown command: {payload}")