def METHOD_NAME(self, my_task):
    # if we were created with thread_starter suppressed, connect it now.
    if self.thread_starter is None:
        self.thread_starter = self.outputs[0]
    outputs = self._get_predicted_outputs(my_task)
    if my_task._is_definite():
        my_task._sync_children(outputs, TaskState.FUTURE)
    else:
        my_task._sync_children(outputs, TaskState.LIKELY)