do not display instructions for end events at the top level of the process w/ burnettk (#414)

Co-authored-by: jasquat <jasquat@users.noreply.github.com>

spiffworkflow-backend/src/spiffworkflow_backend/routes/tasks_controller.py

@@ -445,6 +445,12 @@ def _interstitial_stream(
     tasks = get_reportable_tasks()
     while True:
         for spiff_task in tasks:
+            # ignore the instructions if they are on the EndEvent for the top level process
+            if not TaskService.is_main_process_end_event(spiff_task):
+                print(
+                    "TaskService.get_task_type_from_spiff_task:"
+                    f" {TaskService.get_task_type_from_spiff_task(spiff_task)}"
+                )
                 try:
                     instructions = render_instructions(spiff_task)
                 except Exception as e:
@@ -467,6 +473,8 @@ def _interstitial_stream(
                     return
                 if execute_tasks:
                     try:
+                        # run_until_user_message does not run tasks with instructions to use one_at_a_time
+                        # to force it to run the task.
                         processor.do_engine_steps(execution_strategy_name="one_at_a_time")
                         processor.do_engine_steps(execution_strategy_name="run_until_user_message")
                         processor.save()  # Fixme - maybe find a way not to do this on every loop?
@@ -479,6 +487,9 @@ def _interstitial_stream(
                         yield _render_data("error", api_error)
                         ErrorHandlingService.handle_error(process_instance, wfe)
                         return
+                # return if process instance is now complete and let the frontend redirect to show page
+                if process_instance.status not in ProcessInstanceModel.active_statuses():
+                    return
 
         # path used by the interstitial page while executing tasks - ie the background processor is not executing them
         ready_engine_task_count = _get_ready_engine_step_count(processor.bpmn_process_instance)

spiffworkflow-backend/src/spiffworkflow_backend/services/process_instance_processor.py

@@ -1477,10 +1477,7 @@ class ProcessInstanceProcessor:
         if self.bpmn_process_instance.is_completed():
             for spiff_task in SpiffTask.Iterator(self.bpmn_process_instance.task_tree, TaskState.ANY_MASK):
                 # Assure that we find the end event for this process_instance, and not for any sub-process_instances.
-                if (
+                if TaskService.is_main_process_end_event(spiff_task):
-                    spiff_task.task_spec.__class__.__name__ == "EndEvent"
-                    and spiff_task.workflow == self.bpmn_process_instance
-                ):
                     endtasks.append(spiff_task)
             if len(endtasks) > 0:
                 return endtasks[-1]

spiffworkflow-backend/src/spiffworkflow_backend/services/task_service.py

@@ -613,6 +613,17 @@ class TaskService:
             )
         return task_draft_data
 
+    @classmethod
+    def get_task_type_from_spiff_task(cls, spiff_task: SpiffTask) -> str:
+        # wrap in str so mypy doesn't lose its mind
+        return str(spiff_task.task_spec.__class__.__name__)
+
+    @classmethod
+    def is_main_process_end_event(cls, spiff_task: SpiffTask) -> bool:
+        return (
+            cls.get_task_type_from_spiff_task(spiff_task) == "EndEvent" and spiff_task.workflow.parent_workflow is None
+        )
+
     @classmethod
     def bpmn_process_for_called_activity_or_top_level_process(cls, task_model: TaskModel) -> BpmnProcessModel:
         """Returns either the bpmn process for the call activity calling the process or the top level bpmn process.