fix

4 months ago · 4f75a6ffb7
parent 1bc8b8f8ce
commit 4f75a6ffb7
1 changed files with 2 additions and 1 deletions
--- a/src/aeros_simulation/router.py
+++ b/src/aeros_simulation/router.py
@ -240,7 +240,7 @@ async def calculate_contribution(

        eqs = (await db_session.execute(simulations_eq)).scalars().all()
        
-        batch_size = 100
+        batch_size = 20
        start_index = batch_num * batch_size
        end_index = start_index + batch_size
        
@ -304,6 +304,7 @@ async def calculate_contribution(
            eaf_contributions_data.append(eaf_conf)
            
            await db_session.delete(simulation)
+            await db_session.commit()

        db_session.add_all(eaf_contributions_data)
        await db_session.commit()