def find_internal_events(self, replay_dag, inject_input, wait_time_seconds):
    replayer = Replayer(self.simulation_cfg, replay_dag)
    log.debug("Replaying prefix")
    simulation = replayer.simulate()
    newly_inferred_events = play_forward(simulation, inject_input, wait_time_seconds)
    return newly_inferred_events
Replay the replay_dag, then wait for wait_time_seconds and collect internal
dataset/ETHPy150Open ucb-sts/sts/sts/control_flow/peeker.py/PrefixPeeker.find_internal_events