snapshot

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)

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