def _atomic_input_events(self, inputs):
    # TODO(cs): memoize?
    skipped_recoveries = set()
    atomic_inputs = []
    for e in inputs:
      if e in skipped_recoveries:
        continue

      if type(e) in self._failure_types and e.dependent_labels != []:
        recoveries = []
        for label in e.dependent_labels:
          recovery = self._label2event[label]
          skipped_recoveries.add(recovery)
          recoveries.append(recovery)
        atomic_inputs.append(AtomicInput(e, recoveries))
      else:
        atomic_inputs.append(e)
    return atomic_inputs
dataset/ETHPy150Open ucb-sts/sts/sts/event_dag.py/EventDag._atomic_input_events/original