def METHOD_NAME(session: DbSession, owner: str, key: str) -> None:
    update_stmt = (
        update(AggregateDb)
        .values(dirty=True)
        .where((AggregateDb.key == key) & (AggregateDb.owner == owner))
    )
    session.execute(update_stmt)