def _on_trigger(self, task_spec):
<EOL>my_task = self._find_my_task(task_spec)<EOL>if my_task._has_state(Task.COMPLETED):<EOL><INDENT>state = Task.READY<EOL><DEDENT>else:<EOL><INDENT>state = Task.FUTURE<EOL><DEDENT>for output in self.outputs:<EOL><INDENT>new_task = my_task._add_child(output, state)<EOL>new_task.triggered = True<EOL>output._predict(new_task)<EOL><DEDENT>
May be called after execute() was already completed to create an
additional outbound task.