fix: Fix workflow failure handling

Author: Alan Christie

workflow/workflow_engine.py

@@ -167,7 +167,7 @@ def _handle_pod_message(self, msg: PodMessage) -> None:
         response = self._api_adapter.get_workflow(workflow_id=workflow_id)
         workflow = response["workflow"]
 
-        end_of_workflow: bool = False
+        end_of_workflow: bool = True
         if success:
             # Given the step for the instance just finished,
             # find the next step in the workflow and launch it.
@@ -195,9 +195,8 @@ def _handle_pod_message(self, msg: PodMessage) -> None:
                             workflow_definition=workflow,
                             step_specification=step_specification,
                         )
+                        end_of_workflow = False
                         break
-                    else:
-                        end_of_workflow = True
 
         if end_of_workflow:
             self._api_adapter.set_running_workflow_done(