diff --git a/arc-batch/src/main/java/fr/insee/arc/batch/BatchARC.java b/arc-batch/src/main/java/fr/insee/arc/batch/BatchARC.java index 5aae1e4fc..7f7f7f510 100644 --- a/arc-batch/src/main/java/fr/insee/arc/batch/BatchARC.java +++ b/arc-batch/src/main/java/fr/insee/arc/batch/BatchARC.java @@ -499,10 +499,10 @@ private void resetWorkDirectory() throws ArcException, IOException { * @param pool * @return */ - private int initializeBatchLoop(ArrayList phases, + private void initializeBatchLoop(ArrayList phases, HashMap> pool) { int stepNumber = (TraitementPhase.MAPPING.getOrdre() - TraitementPhase.CHARGEMENT.getOrdre()) + 2; - int delay = poolingDelay / stepNumber; + this.delay = poolingDelay / stepNumber; message("Initialisation boucle Chargement->Mapping"); @@ -519,7 +519,7 @@ private int initializeBatchLoop(ArrayList phases, for (TraitementPhase phase : phases) { pool.put(phase, new ArrayList<>()); } - return delay; + } /** @@ -536,7 +536,7 @@ private void executeLoopOverPhases() throws ArcException return; } - this.delay = initializeBatchLoop(phases, pool); + initializeBatchLoop(phases, pool); // boucle de chargement message("Début de la boucle d'itération");