Finalement même tout un département c'est long

alembic/versions/42ff9c981be7_ajout_des_modèles_de_résultats_pour_les_.py

@@ -104,7 +104,7 @@ def upgrade() -> None:
     )
     op.create_table('circonscription',
     sa.Column('id', sa.String(length=6), nullable=False),
-    sa.Column('departement_code', sa.String(length=2), nullable=False),
+    sa.Column('departement_code', sa.String(length=3), nullable=False),
     sa.Column('numero', sa.Integer(), nullable=False),
     sa.ForeignKeyConstraint(['departement_code'], ['departement.code_insee'], ),
     sa.PrimaryKeyConstraint('id')
@@ -119,7 +119,7 @@ def upgrade() -> None:
     )
     op.create_table('resultats2024_departement',
     sa.Column('id', sa.Integer(), nullable=False),
-    sa.Column('dpt_id', sa.String(length=2), nullable=False),
+    sa.Column('dpt_id', sa.String(length=3), nullable=False),
     sa.Column('resultats_region_id', sa.Integer(), nullable=False),
     sa.Column('inscrits', sa.Integer(), nullable=False),
     sa.Column('votants', sa.Integer(), nullable=False),

nupes/scripts/export_resultats_2024.py

@@ -201,8 +201,7 @@ def exporter_resultats_departements(engine: Engine) -> None:
 
 def exporter_resultats_communes(engine: Engine) -> None:
     with Session(engine) as session:
-        # FIXME On n'importe que les communes du Bas-Rhin pour des raisons de gain de temps
+        communes = session.execute(select(Commune)).scalars().all()
-        communes = session.execute(select(Commune).filter_by(departement_code="67")).scalars().all()
         communes_json = []
 
         for commune in tqdm(communes, desc="Communes"):
@@ -258,4 +257,5 @@ def run(engine: Engine) -> None:
     exporter_resultats_france(engine)
     exporter_resultats_regions(engine)
     exporter_resultats_departements(engine)
-    exporter_resultats_communes(engine)
+    # FIXME Les communes prennent trop de temps
+    # exporter_resultats_communes(engine)

nupes/scripts/import_resultats_web_2024.py

@@ -170,8 +170,7 @@ def importer_resultats_departements(engine: Engine) -> None:
 
 def importer_resultats_communes(engine: Engine) -> None:
     with Session(engine) as session:
-        # FIXME On n'importe que les communes du Bas-Rhin pour des raisons de gain de temps
+        for commune in tqdm(session.execute(select(Commune)).scalars().all(), desc="Communes"):
-        for commune in tqdm(session.execute(select(Commune).filter_by(departement_code="67")).scalars().all(), desc="Communes"):
             reg_code = commune.departement.region_code
             reg_path = f"{reg_code}/"
             dpt_code = commune.departement_code
@@ -295,4 +294,5 @@ def run(engine: Engine) -> None:
     importer_resultats_france(engine)
     importer_resultats_regions(engine)
     importer_resultats_departements(engine)
-    importer_resultats_communes(engine)
+    # FIXME Les communes prennent trop de temps
+    # importer_resultats_communes(engine)