diff --git a/src/radical/utils/flux.py b/src/radical/utils/flux.py index 374d34d7..3df53982 100644 --- a/src/radical/utils/flux.py +++ b/src/radical/utils/flux.py @@ -446,10 +446,10 @@ def connect_flux(self, uri : Optional[str] = None) -> None: with self._lock: - with ru_open(self._uid + '.dump', 'a') as fout: - fout.write('connect flux %d: %s\n' % (os.getpid(), uri)) - for l in get_stacktrace(): - fout.write(l + '\n') + # with ru_open(self._uid + '.dump', 'a') as fout: + # fout.write('connect flux %d: %s\n' % (os.getpid(), uri)) + # for l in get_stacktrace(): + # fout.write(l + '\n') if self._uri: raise RuntimeError('service already connected: %s' % self._uri) diff --git a/tests/unittests/test_heartbeat.py b/tests/unittests/test_heartbeat.py index 82c581d6..fc35d1a3 100755 --- a/tests/unittests/test_heartbeat.py +++ b/tests/unittests/test_heartbeat.py @@ -99,6 +99,9 @@ def test_hb_uid(): # -------------------------------------------------------------------------- def proc(): + start = time.time() + print('proc start: %.2f' % (time.time() - start)) + hb = ru.Heartbeat('test', timeout=0.1, interval=0.01) t0 = time.time() @@ -112,7 +115,7 @@ def proc(): time.sleep(0.1) while True: - time.sleep(1) + time.sleep(0.1) finally: if time.time() > t0 + 3.2: @@ -129,7 +132,7 @@ def proc(): assert p.is_alive() # but it should have a zero exit value after 2 more seconds - time.sleep(6) + time.sleep(3) assert not p.is_alive() assert p.exitcode