async def METHOD_NAME(
    session_factory: DbSessionFactory,
) -> Sequence[MessageDb]:
    messages = await _load_fixtures(
        session_factory, "fixture_aggregates.json", raw=False
    )
    aggregate_keys = set()
    with session_factory() as session:
        for message in messages:
            aggregate_element = make_aggregate_element(message)  # type: ignore
            session.add(aggregate_element)
            aggregate_keys.add((aggregate_element.owner, aggregate_element.key))
        session.commit()
        for owner, key in aggregate_keys:
            refresh_aggregate(session=session, owner=owner, key=key)
        session.commit()
    return messages  # type: ignore