def METHOD_NAME(self, my_task):
    subprocess = my_task.workflow.top_workflow.subprocesses.get(my_task.id)
    if subprocess is None:
        super().METHOD_NAME(my_task)
        self.create_workflow(my_task)
        self.start_workflow(my_task)
        my_task._set_state(TaskState.WAITING)
    else:
        return subprocess.is_completed()