

def _clean_room_for_join_txn(self, txn, room_id):
    query = 'DELETE FROM event_forward_extremities WHERE room_id = ?'
    txn.execute(query, (room_id,))
    txn.call_after(self.get_latest_event_ids_in_room.invalidate, (room_id,))

dataset/ETHPy150Open matrix-org/synapse/synapse/storage/event_federation.py EventFederationStore._clean_room_for_join_txn/original