(tooling-trusted-release) branch main updated: Exit after rsync failures and debug vote announcement email send results

[sb...@apache.org]

This is an automated email from the ASF dual-hosted git repository.

sbp pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/tooling-trusted-release.git


The following commit(s) were added to refs/heads/main by this push:
     new ed65fca  Exit after rsync failures and debug vote announcement email send results
ed65fca is described below

commit ed65fca39a0deb9c6db654f755bcf6bf18dc894e
Author: Sean B. Palmer <se...@miscoranda.com>
AuthorDate: Fri Apr 4 15:49:37 2025 +0100

    Exit after rsync failures and debug vote announcement email send results
---
 atr/routes/candidate.py | 2 ++
 atr/ssh.py              | 5 +++++
 2 files changed, 7 insertions(+)

diff --git a/atr/routes/candidate.py b/atr/routes/candidate.py
index dc49ab9..49508c6 100644
--- a/atr/routes/candidate.py
+++ b/atr/routes/candidate.py
@@ -18,6 +18,7 @@
 """candidate.py"""
 
 import json
+import logging
 
 import aiofiles.os
 import aioshutil
@@ -352,6 +353,7 @@ async def _resolve_get(session: routes.CommitterSession) -> str:
                     parsed_result = {}
 
                 if isinstance(parsed_result, dict):
+                    logging.info(f"Vote task result: {parsed_result}")
                     task_mid = parsed_result.get("mid", "(mid not found in result)")
                 else:
                     task_mid = "(no result)"
diff --git a/atr/ssh.py b/atr/ssh.py
index 1bcae8d..ad7fb2b 100644
--- a/atr/ssh.py
+++ b/atr/ssh.py
@@ -284,6 +284,10 @@ async def _handle_client(process: asyncssh.SSHServerProcess) -> None:
 
         # Wait for the process to complete
         exit_status = await proc.wait()
+        if exit_status != 0:
+            _LOGGER.error(f"Command {process.command} failed with exit status {exit_status}")
+            process.exit(exit_status)
+            return
 
         # Start a task to process the new files
         async with db.session() as data:
@@ -322,6 +326,7 @@ async def _handle_client(process: asyncssh.SSHServerProcess) -> None:
             await data.commit()
 
         # Exit the SSH process with the same status as the rsync process
+        # Should be 0 here
         process.exit(exit_status)
 
     except Exception as e:


---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscribe@tooling.apache.org
For additional commands, e-mail: commits-help@tooling.apache.org