(self, my_task)
| 202 | return may_fire |
| 203 | |
| 204 | def _find_tasks(self, my_task): |
| 205 | |
| 206 | split_task = my_task.find_ancestor(self.split_task) or my_task.workflow.task_tree |
| 207 | # Identify all corresponding task instances within the thread. |
| 208 | thread_tasks = [] |
| 209 | for task in TaskIterator(split_task, spec_name=self.name, end_at_spec=self.name): |
| 210 | # Ignore tasks from other threads. |
| 211 | if task.thread_id != my_task.thread_id: |
| 212 | continue |
| 213 | # Ignore my outgoing branches. |
| 214 | if self.split_task and task.is_descendant_of(my_task): |
| 215 | continue |
| 216 | # We have found a matching instance. |
| 217 | thread_tasks.append(task) |
| 218 | return thread_tasks |
| 219 | |
| 220 | def _do_join(self, my_task): |
| 221 |
no test coverage detected