From fb3271aa4ef44dcecdfead50d9e0a5fb8aad58fc Mon Sep 17 00:00:00 2001 From: Tasos Papaioannou Date: Thu, 19 Sep 2024 18:15:59 -0400 Subject: [PATCH] Debug PRT --- broker/hosts.py | 1 + broker/session.py | 3 +++ 2 files changed, 4 insertions(+) diff --git a/broker/hosts.py b/broker/hosts.py index 1149469f..d091cefe 100644 --- a/broker/hosts.py +++ b/broker/hosts.py @@ -161,6 +161,7 @@ def execute(self, command, timeout=None): Returns: str: The output of the command executed on the host. """ + breakpoint() timeout = timeout or self.default_timeout logger.debug(f"{self.hostname} executing command: {command}") res = self.session.run(command, timeout=timeout) diff --git a/broker/session.py b/broker/session.py index 4abddfd9..f5fad49a 100644 --- a/broker/session.py +++ b/broker/session.py @@ -79,10 +79,13 @@ def run(self, command, demux=True, **kwargs): # Containers don't handle pipes, redirects, etc well in a bare exec_run command = f"/bin/bash -c '{command}'" result = self._cont_inst._cont_inst.exec_run(command, **kwargs) + logger.info(f"tpapaioa ContainerSession result 1: {command=} {result=}") if demux: result = helpers.Result.from_duplexed_exec(result, self.runtime) + logger.info(f"tpapaioa ContainerSession result demux: {result=}") else: result = helpers.Result.from_nonduplexed_exec(result) + logger.info(f"tpapaioa ContainerSession result nonduplex: {result=}") return result def disconnect(self):