diff --git a/pioreactor/cli/pios.py b/pioreactor/cli/pios.py index 68889bbb..79232c1e 100644 --- a/pioreactor/cli/pios.py +++ b/pioreactor/cli/pios.py @@ -570,7 +570,7 @@ def _thread_function(unit: str) -> bool: logger.debug(f"Syncing configs on {unit}...") try: sync_config_files(unit, shared, specific) - logger.debug(f"worker for {unit}?") + logger.debug(f"worked for {unit}?") return True except RsyncError as e: logger.warning(f"Could not transfer config to {unit}. Is it online?") @@ -589,9 +589,7 @@ def _thread_function(unit: str) -> bool: results = executor.map(_thread_function, units) if not all(results): - print(results) sys.exit(1) - print(results) @pios.command("kill", short_help="kill a job(s) on workers") @click.option("--job") diff --git a/pioreactor/utils/networking.py b/pioreactor/utils/networking.py index 85ef8923..638f1f2e 100644 --- a/pioreactor/utils/networking.py +++ b/pioreactor/utils/networking.py @@ -15,8 +15,11 @@ def rsync(*args: str) -> None: from subprocess import check_call from subprocess import CalledProcessError + from pioreactor.logging import create_logger + l = create_logger("rsync") try: + l.info("rsync" + " ".join(args)) check_call(("rsync",) + args, stdout=subprocess.DEVNULL, stderr=subprocess.STDOUT) except CalledProcessError as e: raise RsyncError from e