bugfix

brancheneinstufung.py

@@ -5257,37 +5257,31 @@ class DataProcessor:
             return # Beende die Methode
 
 
-        # Verarbeitung der markierten Zeilen
-        processed_count = 0
-        
-        # Iteriere ueber die gefundenen markierten Zeilen
-        processed_count = 0 # Zähler für tatsächlich verarbeitete Zeilen (für das Limit)
-        # row_limit kommt als Parameter in die Funktion (z.B. args.limit)
+          processed_count_actual = 0 # Neuer Zähler für tatsächlich verarbeitete Zeilen
         
         for task in rows_to_process:
-            # --- KORREKTUR HIER: Direkte Limit-Prüfung ---
-            if row_limit is not None and isinstance(row_limit, int) and row_limit > 0 and processed_count >= row_limit:
-                self.logger.info(f"Zeilenlimit ({row_limit}) fuer Re-Evaluation erreicht. Breche weitere Verarbeitung ab. Bereits verarbeitet: {processed_count}")
-                break 
-            # --- ENDE KORREKTUR ---
-
             row_num = task['row_num']
             row_data = task['data']
 
+            if limit is not None and isinstance(limit, int) and limit > 0 and processed_count_actual >= limit:
+                self.logger.info(f"Zeilenlimit ({limit}) fuer Re-Evaluation erreicht. Breche weitere Verarbeitung ab. Bereits verarbeitet: {processed_count_actual}")
+                break 
+            
             self.logger.info(f"Bearbeite Re-Eval Zeile {row_num}...")
+            processed_count_actual += 1 # Inkrementiere, da diese Zeile jetzt verarbeitet wird
             try:
                 self._process_single_row( 
                     row_num_in_sheet = row_num,
                     row_data = row_data,
-                    steps_to_run = steps_to_run_set, # steps_to_run_set muss hier korrekt übergeben werden
+                    steps_to_run = steps_to_run_set,
                     force_reeval = True, 
-                    clear_x_flag = clear_flag # clear_flag kommt als Parameter in die Funktion
+                    clear_x_flag = clear_flag
                 )
-                processed_count += 1 # Zähle nur, wenn _process_single_row ohne Exception durchlief
-            except Exception as e_proc_reval_main: # Umbenannt, um Konflikt zu vermeiden
+                # Zähle processed_count hier nicht mehr, da es oben passiert
+            except Exception as e_proc_reval_main:
                 self.logger.exception(f"FEHLER bei Re-Evaluation von Zeile {row_num} in process_reevaluation_rows: {e_proc_reval_main}")
         
-        self.logger.info(f"Re-Evaluierung abgeschlossen. {processed_count} Zeilen verarbeitet (Gefunden: {found_count}, CLI-Limit war: {row_limit}).")
+        self.logger.info(f"Re-Evaluierung abgeschlossen. {processed_count_actual} Zeilen verarbeitet (Gefunden mit 'x': {found_count}, CLI-Limit war: {limit}).")
 
 
     # ==============================================================================