(self, my_task)
| 41 | self.event_type = event_type |
| 42 | |
| 43 | def _predict_hook(self, my_task): |
| 44 | # Events attached to the main task might occur |
| 45 | my_task._sync_children(self.outputs, state=TaskState.MAYBE) |
| 46 | # The main child's state is based on this task's state |
| 47 | state = TaskState.FUTURE if my_task.has_state(TaskState.DEFINITE_MASK) else my_task.state |
| 48 | for child in my_task.children: |
| 49 | if not isinstance(child.task_spec, self.event_type): |
| 50 | child._set_state(state) |
| 51 | |
| 52 | def _run_hook(self, my_task): |
| 53 | for task in my_task.children: |
nothing calls this directly
no test coverage detected