Skip to content

Commit

Permalink
try this
Browse files Browse the repository at this point in the history
  • Loading branch information
CamDavidsonPilon committed Jan 11, 2025
1 parent 9a668f2 commit 13049d5
Show file tree
Hide file tree
Showing 2 changed files with 4 additions and 3 deletions.
4 changes: 1 addition & 3 deletions pioreactor/cli/pios.py
Original file line number Diff line number Diff line change
Expand Up @@ -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?")
Expand All @@ -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")
Expand Down
3 changes: 3 additions & 0 deletions pioreactor/utils/networking.py
Original file line number Diff line number Diff line change
Expand Up @@ -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
Expand Down

0 comments on commit 13049d5

Please sign in to comment.