diff --git a/src/radical/utils/flux.py b/src/radical/utils/flux.py index ace552f8..bec64006 100644 --- a/src/radical/utils/flux.py +++ b/src/radical/utils/flux.py @@ -88,6 +88,9 @@ def _watch(self) -> None: for k,v in self._env.items(): os.environ[k] = v + out, err, ret = sh_callout('flux resource list') + self._log.info('flux resources [ %d %s]:\n%s', ret, err, out) + while not self._term.is_set(): time.sleep(1)