Compare commits

..

No commits in common. "24f1dafd990fa49536b438ed48d0e9ebe9918807" and "3c0b03c5766d51c5de52273daae67a9fe21ea9b2" have entirely different histories.

3 changed files with 8 additions and 8 deletions

View File

@ -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=3), nullable=False),
sa.Column('departement_code', sa.String(length=2), 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=3), nullable=False),
sa.Column('dpt_id', sa.String(length=2), 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),

View File

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

View File

@ -170,7 +170,8 @@ def importer_resultats_departements(engine: Engine) -> None:
def importer_resultats_communes(engine: Engine) -> None:
with Session(engine) as session:
for commune in tqdm(session.execute(select(Commune)).scalars().all(), desc="Communes"):
# 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).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
@ -294,5 +295,4 @@ def run(engine: Engine) -> None:
importer_resultats_france(engine)
importer_resultats_regions(engine)
importer_resultats_departements(engine)
# FIXME Les communes prennent trop de temps
# importer_resultats_communes(engine)
importer_resultats_communes(engine)