Floke/Brancheneinstufung2
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

bugfix

Browse Source
This commit is contained in:
Floke
2025-05-30 13:57:50 +00:00
parent 7bd415620b
commit fe4c873586
1 changed files with 8 additions and 12 deletions
Download Patch File Download Diff File Expand all files Collapse all files

20
brancheneinstufung.py
View File

@@ -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.