Method _check_threshold_structured

SpiffWorkflow/specs/Join.py:156–181

(self, my_task)

        return True

    def _check_threshold_structured(self, my_task):
        # Retrieve a list of all activated tasks from the associated task that did the conditional parallel split.
        split_task = my_task.find_ancestor(self.split_task)
        if split_task is None:
            raise WorkflowException(f'Split task {self.split_task} which was not reached', task_spec=self)
        tasks = split_task.task_spec._get_activated_tasks(split_task, my_task)

        # The default threshold is the number of branches that were started.
        threshold = valueof(my_task, self.threshold)
        if threshold is None:
            threshold = len(tasks)

        # Look up which tasks have already completed.
        waiting_tasks = []
        completed = 0

        for task in tasks:
            if self._branch_is_complete(task):
                completed += 1
            elif not self._branch_may_merge(task):
                completed += 1
            else:
                waiting_tasks.append(task)

        # If the threshold was reached, get ready to fire.
        return completed >= threshold, waiting_tasks

    def _update_hook(self, my_task):