From fe4c873586a0568c38c939dc98a6b7ef350e9625 Mon Sep 17 00:00:00 2001 From: Floke Date: Fri, 30 May 2025 13:57:50 +0000 Subject: [PATCH] bugfix --- brancheneinstufung.py | 20 ++++++++------------ 1 file changed, 8 insertions(+), 12 deletions(-) diff --git a/brancheneinstufung.py b/brancheneinstufung.py index 48360b12..b97e630b 100644 --- a/brancheneinstufung.py +++ b/brancheneinstufung.py @@ -4663,7 +4663,7 @@ class DataProcessor: # Timestamp für Wikipedia-Extraktion (Z) immer setzen, wenn der Wiki-Schritt lief updates.append({'range': f'{self.sheet_handler._get_col_letter(COLUMN_MAP["Wikipedia Timestamp"] + 1)}{row_num_in_sheet}', 'values': [[now_timestamp]]}) -# Innerhalb von DataProcessor._process_single_row (NEUER Wiki-Block) + # Innerhalb von DataProcessor._process_single_row (NEUER Wiki-Block) # --- 2. Wikipedia Handling (Search, Extraction, Status Reset) ========== run_wiki_step = 'wiki' in steps_to_run @@ -5406,12 +5406,8 @@ class DataProcessor: # Iteriere ueber die gefundenen markierten Zeilen for task in rows_to_process: - # === HIER DIE DEBUG-AUSGABE EINFÜGEN === - self.logger.debug(f"Re-Eval Loop Check: processed_count={processed_count}, row_limit={row_limit}") - # === ENDE DEBUG-AUSGABE === - - 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. Processed: {processed_count}") + if self.limit_erreicht(processed_count, row_limit): # Eine Hilfsfunktion oder direkte Prüfung + self.logger.info(f"Zeilenlimit ({row_limit}) fuer Re-Evaluation erreicht. Breche weitere Verarbeitung ab.") break row_num = task['row_num'] @@ -5419,16 +5415,16 @@ class DataProcessor: self.logger.info(f"Bearbeite Re-Eval Zeile {row_num}...") try: - self._process_single_row( + self._process_single_row( # Hier werden die steps_to_run übergeben row_num_in_sheet = row_num, row_data = row_data, - steps_to_run = steps_to_run_set, + steps_to_run = steps_to_run_set, # Das Set der zu laufenden Schritte force_reeval = True, clear_x_flag = clear_flag ) - processed_count += 1 - except Exception as e_proc: - self.logger.exception(f"FEHLER bei Re-Evaluation von Zeile {row_num}: {e_proc}") + processed_count += 1 # Zähle nur, wenn _process_single_row ohne Exception durchlief + except Exception as e_proc_reval: + self.logger.exception(f"FEHLER bei Re-Evaluation von Zeile {row_num} in process_reevaluation_rows: {e_proc_reval}") # Hier koennen Sie z.B. einen Fehlerindikator in eine spezielle Spalte im Sheet schreiben lassen. # Dieses Update muesste dann separat oder im naechsten Lauf behandelt werden.