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

Anpassung reeval

Browse Source
This commit is contained in:
Floke
2025-07-19 15:38:56 +00:00
parent bdb27d06bd
commit 39215bf79d
1 changed files with 11 additions and 10 deletions
Download Patch File Download Diff File Expand all files Collapse all files

19
data_processor.py
View File

@@ -955,8 +955,10 @@ class DataProcessor:
self.logger.warning("Keine Datenzeilen fuer Re-Evaluation gefunden.") self.logger.warning("Keine Datenzeilen fuer Re-Evaluation gefunden.")
return return
reeval_col_idx = COLUMN_MAP.get("ReEval Flag") column_names = list(COLUMN_MAP.keys())
if reeval_col_idx is None: try:
reeval_col_idx = column_names.index("ReEval Flag")
except ValueError:
self.logger.critical("FEHLER: 'ReEval Flag' nicht in COLUMN_MAP. Breche ab.") self.logger.critical("FEHLER: 'ReEval Flag' nicht in COLUMN_MAP. Breche ab.")
return return
@@ -970,14 +972,12 @@ class DataProcessor:
self.logger.info(f"{found_count} Zeilen mit ReEval-Flag 'x' gefunden.") self.logger.info(f"{found_count} Zeilen mit ReEval-Flag 'x' gefunden.")
if found_count == 0: return if found_count == 0: return
# --- AB HIER BEGINNT DER FEHLENDE TEIL ---
# Spalten definieren, die vor der Neubewertung geleert werden sollen # Spalten definieren, die vor der Neubewertung geleert werden sollen
cols_to_clear_keys = [ cols_to_clear_keys = [
"Wiki Sitz Stadt", "Wiki Sitz Land", "Wiki Absatz", "Wiki Branche", "Wiki URL", "Wiki Sitz Stadt", "Wiki Sitz Land", "Wiki Absatz", "Wiki Branche",
"Wiki Umsatz", "Wiki Mitarbeiter", "Wiki Kategorien", "Wikipedia Timestamp", "Wiki Umsatz", "Wiki Mitarbeiter", "Wiki Kategorien", "Wikipedia Timestamp",
"Wiki Verif. Timestamp", "SerpAPI Wiki Search Timestamp", "Chat Wiki Konsistenzpruefung", "Wiki Verif. Timestamp", "SerpAPI Wiki Search Timestamp", "Chat Wiki Konsistenzpruefung",
"Chat Begründung Wiki Inkonsistenz", "Chat Vorschlag Wiki Artikel", "Begründung bei Abweichung", "Chat Begruendung Wiki Inkonsistenz", "Chat Vorschlag Wiki Artikel", "Begründung bei Abweichung",
"Website Rohtext", "Website Zusammenfassung", "Website Meta-Details", "Website Scrape Timestamp", "URL Prüfstatus", "Website Rohtext", "Website Zusammenfassung", "Website Meta-Details", "Website Scrape Timestamp", "URL Prüfstatus",
"Chat Vorschlag Branche", "Chat Branche Konfidenz", "Chat Konsistenz Branche", "Chat Vorschlag Branche", "Chat Branche Konfidenz", "Chat Konsistenz Branche",
"Chat Begruendung Abweichung Branche", "Finaler Umsatz (Wiki>CRM)", "Finaler Mitarbeiter (Wiki>CRM)", "Chat Begruendung Abweichung Branche", "Finaler Umsatz (Wiki>CRM)", "Finaler Mitarbeiter (Wiki>CRM)",
@@ -991,10 +991,12 @@ class DataProcessor:
for task in rows_to_process: for task in rows_to_process:
row_num = task['row_num'] row_num = task['row_num']
for key in cols_to_clear_keys: for key in cols_to_clear_keys:
col_idx = COLUMN_MAP.get(key) try:
if col_idx is not None: col_idx = column_names.index(key)
col_letter = self.sheet_handler._get_col_letter(col_idx + 1) col_letter = self.sheet_handler._get_col_letter(col_idx + 1)
clear_updates.append({'range': f'{col_letter}{row_num}', 'values': [['']]}) clear_updates.append({'range': f'{col_letter}{row_num}', 'values': [['']]})
except ValueError:
self.logger.warning(f"Spalte '{key}' zum Leeren im Re-Eval-Modus nicht in COLUMN_MAP gefunden. Überspringe.")
if clear_updates: if clear_updates:
self.logger.info(f"Leere {len(clear_updates)} Zellen für {found_count} Re-Eval-Zeilen zur Vorbereitung...") self.logger.info(f"Leere {len(clear_updates)} Zellen für {found_count} Re-Eval-Zeilen zur Vorbereitung...")
@@ -1003,7 +1005,6 @@ class DataProcessor:
time.sleep(2) time.sleep(2)
self.sheet_handler.load_data() self.sheet_handler.load_data()
# Verarbeitung der Zeilen nach dem Leeren
processed_count_actual = 0 processed_count_actual = 0
steps_to_run_set = set(key for key, value in {'wiki': process_wiki_steps, 'chat': process_chatgpt_steps, 'web': process_website_steps, 'ml_predict': process_ml_steps}.items() if value) steps_to_run_set = set(key for key, value in {'wiki': process_wiki_steps, 'chat': process_chatgpt_steps, 'web': process_website_steps, 'ml_predict': process_ml_steps}.items() if value)