fix bug

sematic-ai · Apr 15, 2024 · 9a700a9 · 9a700a9
1 parent b379817
commit 9a700a9
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/sematic/runners/state_machine_runner.py b/sematic/runners/state_machine_runner.py
@@ -103,6 +103,7 @@ def _pipeline_run_loop(self):
                     )
 
             if not state_changed:
+                logger.info("Entering wait")
                 # we only want to enter a waiting state if nothing changed.
                 # otherwise there might be other things we can schedule
                 # before starting the wait.
@@ -472,8 +473,7 @@ def _schedule_future_if_args_concrete(self, future: AbstractFuture) -> bool:
 
         if all_args_concrete:
             future.resolved_kwargs = concrete_kwargs
-            self._execute_future(future)
-            return True
+            return self._execute_future(future)
         return False
 
     def _execute_future(self, future: AbstractFuture) -> bool: