Merge branch 'fix/run_this_state_unit_test' into 'develop'

fix: run this state unit test

See merge request dev/sys/tci/rafcon!85

Author: vahidm1993

tests/assets/unit_test_state_machines/test_run_this_state/statemachine.json

@@ -1,7 +1,6 @@
 {
     "creation_time": "2021-11-22 14:35:11", 
-    "last_update": "2021-11-22 15:49:02", 
     "root_state_storage_id": "test_run_this_state_BTWFZQ", 
     "state_machine_version": null, 
-    "used_rafcon_version": "0.14.9"
+    "used_rafcon_version": "1.0.0"
 }

tests/assets/unit_test_state_machines/test_run_this_state/test_run_this_state_BTWFZQ/ExecutionState_2_EPQSTG/script.py

@@ -1,4 +1,5 @@
 def execute(self, inputs, outputs, gvm):
     self.logger.info("Hello {}".format(self.name))
     gvm.set_variable("test_value", 2)
+    self.logger.info(gvm.get_variable("test_value"))
     return "success"

tests/core/test_run_selected_state.py

@@ -1,12 +1,12 @@
 import os
-import time
-
+import threading
 # core elements
 from rafcon.core.states.state import StateExecutionStatus
 
 from rafcon.core.storage import storage
 import rafcon.core.singleton
 from rafcon.core.singleton import state_machine_execution_engine
+from tests.utils import wait_for_execution_engine_sync_counter
 from rafcon.utils import log
 
 # test environment elements
@@ -23,19 +23,12 @@ def test_run_this_state(caplog):
     sm = storage.load_state_machine_from_path(testing_utils.get_test_sm_path(os.path.join(
         "unit_test_state_machines", "test_run_this_state")))
     rafcon.core.singleton.state_machine_manager.add_state_machine(sm)
-    # Set state machine as active state machine
-    # rafcon.core.singleton.state_machine_manager.active_state_machine_id = state_machine.state_machine_id
     # Run selected state machine
+    rafcon.core.singleton.global_variable_manager.set_variable("test_value", 1)
     state_machine_execution_engine.run_selected_state("BTWFZQ/EPQSTG", sm.state_machine_id)
-    timeout = time.time()
-    while not sm.get_state_by_path("BTWFZQ/EPQSTG").state_execution_status is StateExecutionStatus.WAIT_FOR_NEXT_STATE:
-        time.sleep(.05)
-        if time.time()-timeout > 2:
-            raise RuntimeError("execution_state EPQSTG didn't run --> timeout")
-    # Stop execution engine
+    wait_for_execution_engine_sync_counter(1, logger)
     state_machine_execution_engine.stop()
     rafcon.core.singleton.state_machine_execution_engine.join()
-
     # assert variable state
     try:
         assert rafcon.core.singleton.global_variable_manager.get_variable("test_value") == 2