diff --git a/app.py b/app.py index 92e4abb..0bab098 100644 --- a/app.py +++ b/app.py @@ -589,6 +589,7 @@ def do_copy(src_devs, dst_dev, cfg): dst_mp = None dst_owned = False src_mounts = [] # [(src_dev, src_mp, src_owned)] + _upload_thread = None try: with copy_lock: copy_state.update(running=True, progress=0, error=None, @@ -809,7 +810,8 @@ def do_copy(src_devs, dst_dev, cfg): add_log('Fertig! ' + ', '.join(msg_parts)) dst_dir_root = Path(dst_mp) / date_str - threading.Thread(target=run_uploads, args=(dst_dir_root, cfg), daemon=True).start() + _upload_thread = threading.Thread(target=run_uploads, args=(dst_dir_root, cfg), daemon=True) + _upload_thread.start() except Exception as e: log.exception('Copy failed') @@ -818,6 +820,10 @@ def do_copy(src_devs, dst_dev, cfg): add_log(f'Fehler: {e}') finally: + # Erst warten bis NAS-Upload fertig, dann erst unmounten + if _upload_thread is not None and _upload_thread.is_alive(): + add_log('Warte auf NAS-Upload vor Unmount...') + _upload_thread.join() subprocess.run(['sync'], capture_output=True) for _, src_mp_i, src_owned_i in src_mounts: if src_owned_i and src_mp_i: @@ -947,6 +953,7 @@ def run_uploads(local_dir: Path, cfg: dict): dest_root = t.get('dest_path', 'PiCopy').strip('/') dest = f'{_remote_name(t["id"])}:{dest_root}' + _rclone('mkdir', dest, timeout=30) # Zielordner anlegen falls nicht vorhanden r = _rclone('copy', str(local_dir), dest, '--create-empty-src-dirs', '--retries', '3', diff --git a/version.txt b/version.txt index 99f7422..cd63089 100644 --- a/version.txt +++ b/version.txt @@ -1 +1 @@ -1.0.39 \ No newline at end of file +1.0.40 \ No newline at end of file