def METHOD_NAME(
    join: JoinClause[EntitySource], graph: EquivalenceGraph
) -> None:
    override_entity_map(EntityKey.EVENTS, Events())
    override_entity_map(EntityKey.GROUPEDMESSAGE, GroupedMessage())
    override_entity_map(EntityKey.GROUPASSIGNEE, GroupAssignee())
    assert get_equivalent_columns(join) == graph
    reset_entity_factory()