FIX: race condition in test worker made it conditional on hardware sp…

…eed, resolved

beams/tests/test_tree_generator.py

@@ -46,7 +46,7 @@ def test_tree_obj_execution(request):
     ):
         for n in tree.tick():
             print(f"ticking: {n}")
-            time.sleep(0.1)
+            time.sleep(0.05)
             print(f"status of tick: {n.status}")
 
     rel_val = caget("PERC:COMP")
@@ -74,7 +74,7 @@ def test_father_tree_execution(request):
         print((tree.root.status, tree.root.status, ct))
         for n in tree.root.tick():
             print(f"ticking: {n}")
-            time.sleep(0.1)
+            time.sleep(0.05)
             print(f"status of tick: {n.status}")
 
     check_insert = caget("RET:INSERT")

beams/tests/test_worker.py

@@ -1,3 +1,4 @@
+import time
 from multiprocessing import Value
 
 from beams.sequencer.helpers.Worker import Worker
@@ -8,11 +9,12 @@ def test_obj_instantiation(self):
     class WorkChild(Worker):
       def __init__(self):
         super().__init__("test_worker")
-        self.value = Value('d', 0)
+        self.value = Value('d', 0)  # Note: here value is a member object 
 
       def work_func(self):
         while (self.do_work.value or self.value.value < 100):
-          self.value.value += 10
+          if (self.value.value < 100):  # Note: here we reference member object
+            self.value.value += 10
 
     w = WorkChild()
     w.start_work()
@@ -22,14 +24,16 @@ def work_func(self):
 
   def test_class_member_instantiation(self):
     a = Worker("test_worker")
-    val = Value('i', 10)
+    val = Value('i', 10)  # Note: value declared here to be captured via closure
 
     def work_func(self):
       while (self.do_work.value or val.value < 100):
-        val.value += 10
+        if (val.value < 100):  # Note: value captured via closure 
+          val.value += 10  # Note: value captured via closure 
     a.set_work_func(work_func)
 
     a.start_work()
+    time.sleep(1)
     a.stop_work()
     assert val.value == 100
 
@@ -38,7 +42,8 @@ def test_inline_instantation(self):
 
     def work_func(self):
       while (self.do_work.value or val.value < 100):
-        val.value += 10
+        if (val.value < 100):  # Note: value captured via closure 
+          val.value += 10
     a = Worker("test_worker", work_func=work_func)
     a.start_work()
     a.stop_work()