async def METHOD_NAME(
    session_factory: DbSessionFactory,
    aggregate_fixtures: Tuple[AggregateDb, Sequence[AggregateElementDb]],
):
    aggregate, elements = aggregate_fixtures
    with session_factory() as session:
        session.add_all(elements)
        session.add(aggregate)
        session.commit()
    with session_factory() as session:
        keys = set(
            get_aggregate_content_keys(
                session=session, key=aggregate.key, owner=aggregate.owner
            )
        )
        assert keys == set(aggregate.content.keys())
    # Test no match
    with session_factory() as session:
        keys = set(
            get_aggregate_content_keys(
                session=session, key="not-a-key", owner="no-one"
            )
        )
        assert keys == set()