hippogrief/pobsync
1
0
Fork 0
Code Issues 21 Pull Requests Actions Packages Projects Releases 3 Wiki Activity

issue-54-worker-rsync-state #56

Merged
parkel merged 3 commits from issue-54-worker-rsync-state into master 2026-05-23 00:39:47 +02:00
Conversation 0 Commits 3 Files Changed 5 +8 -7
1 changed files with 8 additions and 7 deletions
Download Patch File Download Diff File Expand all files Collapse all files
Showing only changes of commit 5788f53854 - Show all commits

15
src/pobsync/commands/run_scheduled.py
View File

@@ -366,13 +366,14 @@ def run_scheduled(
} }
) )
result = run_rsync( run_rsync_kwargs: dict[str, Any] = {
cmd, "log_path": log_path,
log_path=log_path, "timeout_seconds": timeout_seconds,
timeout_seconds=timeout_seconds, "cancel_check": cancel_check,
cancel_check=cancel_check, }
process_started=process_started if state_callback is not None else None, if state_callback is not None:
) run_rsync_kwargs["process_started"] = process_started
result = run_rsync(cmd, **run_rsync_kwargs)
log_tail = _read_log_tail(log_path) log_tail = _read_log_tail(log_path)
warning = classify_rsync_warning(result.exit_code, log_tail) warning = classify_rsync_warning(result.exit_code, log_tail)
successful_or_warning = result.exit_code == 0 or warning is not None successful_or_warning = result.exit_code == 0 or warning is not None