(self, my_task)
| 109 | my_task._set_state(TaskState.WAITING) |
| 110 | |
| 111 | def _run_hook(self, my_task): |
| 112 | # Assign variables, if so requested. |
| 113 | subworkflow = my_task._get_internal_data('subworkflow') |
| 114 | for child in subworkflow.task_tree.children: |
| 115 | for assignment in self.in_assign: |
| 116 | assignment.assign(my_task, child) |
| 117 | child.task_spec._update(child) |
| 118 | return True |
| 119 | |
| 120 | def _update_hook(self, my_task): |
| 121 | super()._update_hook(my_task) |
nothing calls this directly
no test coverage detected