

def callback(self, state, details):
    name = details.get('task_name', None)
    if ((name not in self.wait_for) or (state not in self.wait_states)):
        return
    self.event.set()

dataset/ETHPy150Open openstack/taskflow/taskflow/tests/utils.py WaitForOneFromTask.callback/original