delay between phase as class attribute

InseeFr · Jun 29, 2023 · b250d85 · b250d85
1 parent 750033f
commit b250d85
Showing 1 changed file with 4 additions and 4 deletions.
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
@@ -499,10 +499,10 @@ private void resetWorkDirectory() throws ArcException, IOException {
 	 * @param pool
 	 * @return
 	 */
-	private int initializeBatchLoop(ArrayList<TraitementPhase> phases,
+	private void initializeBatchLoop(ArrayList<TraitementPhase> phases,
 			HashMap<TraitementPhase, ArrayList<PhaseThreadFactory>> 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<TraitementPhase> 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");