diff --git a/brancheneinstufung.py b/brancheneinstufung.py index 08abe71b..193e2be4 100644 --- a/brancheneinstufung.py +++ b/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}).") # ==============================================================================