def _update_extremeties(self, txn, events):
        events_by_room = {}
        for ev in events:
            events_by_room.setdefault(ev.room_id, []).append(ev)

        for room_id, room_events in events_by_room.items():
            prevs = [
                e_id for ev in room_events for e_id, _ in ev.prev_events
                if not ev.internal_metadata.is_outlier()
            ]
            if prevs:
                txn.execute(
                    "DELETE FROM event_forward_extremities"
                    " WHERE room_id = ?"
                    " AND event_id in (%s)" % (
                        ",".join(["?"] * len(prevs)),
                    ),
                    [room_id] + prevs,
                )

        query = (
            "INSERT INTO event_forward_extremities (event_id, room_id)"
            " SELECT ?, ? WHERE NOT EXISTS ("
            " SELECT 1 FROM event_edges WHERE prev_event_id = ?"
            " )"
        )

        txn.executemany(
            query,
            [
                (ev.event_id, ev.room_id, ev.event_id) for ev in events
                if not ev.internal_metadata.is_outlier()
            ]
        )

        query = (
            "INSERT INTO event_backward_extremities (event_id, room_id)"
            " SELECT ?, ? WHERE NOT EXISTS ("
            " SELECT 1 FROM event_backward_extremities"
            " WHERE event_id = ? AND room_id = ?"
            " )"
            " AND NOT EXISTS ("
            " SELECT 1 FROM events WHERE event_id = ? AND room_id = ? "
            " AND outlier = ?"
            " )"
        )

        txn.executemany(query, [
            (e_id, ev.room_id, e_id, ev.room_id, e_id, ev.room_id, False)
            for ev in events for e_id, _ in ev.prev_events
            if not ev.internal_metadata.is_outlier()
        ])

        query = (
            "DELETE FROM event_backward_extremities"
            " WHERE event_id = ? AND room_id = ?"
        )
        txn.executemany(
            query,
            [
                (ev.event_id, ev.room_id) for ev in events
                if not ev.internal_metadata.is_outlier()
            ]
        )

        for room_id in events_by_room:
            txn.call_after(
                self.get_latest_event_ids_in_room.invalidate, (room_id,)
            )
Updates the event_*_extremities tables based on the new/updated
dataset/ETHPy150Open matrix-org/synapse/synapse/storage/event_federation.py/EventFederationStore._update_extremeties