brancheneinstufung2.py aktualisiert
This commit is contained in:
@@ -68,7 +68,9 @@ def main():
|
|||||||
import time
|
import time
|
||||||
import logging
|
import logging
|
||||||
import os
|
import os
|
||||||
from config import Config, log_module_versions, create_log_filename
|
# KORREKTUR HIER: log_module_versions kommt aus helpers, nicht aus config
|
||||||
|
from config import Config, create_log_filename
|
||||||
|
from helpers import log_module_versions
|
||||||
from google_sheet_handler import GoogleSheetHandler
|
from google_sheet_handler import GoogleSheetHandler
|
||||||
from wikipedia_scraper import WikipediaScraper
|
from wikipedia_scraper import WikipediaScraper
|
||||||
from data_processor import DataProcessor
|
from data_processor import DataProcessor
|
||||||
@@ -168,7 +170,6 @@ def main():
|
|||||||
# --- SPEZIFISCHE LOGIK FÜR DEN SYNC-MODUS ---
|
# --- SPEZIFISCHE LOGIK FÜR DEN SYNC-MODUS ---
|
||||||
logger.info("Führe Initialisierung für Sync-Modus durch...")
|
logger.info("Führe Initialisierung für Sync-Modus durch...")
|
||||||
|
|
||||||
# KORREKTUR: Explizites Laden der Sheet-Daten, da der DataProcessor umgangen wird.
|
|
||||||
if not sheet_handler.load_data():
|
if not sheet_handler.load_data():
|
||||||
logger.critical("Konnte initiale Daten aus dem Google Sheet nicht laden. Sync-Prozess wird abgebrochen.")
|
logger.critical("Konnte initiale Daten aus dem Google Sheet nicht laden. Sync-Prozess wird abgebrochen.")
|
||||||
return
|
return
|
||||||
@@ -198,7 +199,6 @@ def main():
|
|||||||
steps_to_run_set = set(step.strip().lower() for step in args.steps.split(',') if step.strip() in valid_steps) if args.steps else set(valid_steps)
|
steps_to_run_set = set(step.strip().lower() for step in args.steps.split(',') if step.strip() in valid_steps) if args.steps else set(valid_steps)
|
||||||
|
|
||||||
if selected_mode == "full_run":
|
if selected_mode == "full_run":
|
||||||
# ... (Rest der Logik bleibt unverändert)
|
|
||||||
start_row = args.start_sheet_row or sheet_handler.get_start_row_index("Timestamp letzte Pruefung") + sheet_handler._header_rows + 1
|
start_row = args.start_sheet_row or sheet_handler.get_start_row_index("Timestamp letzte Pruefung") + sheet_handler._header_rows + 1
|
||||||
num_to_process = args.limit or (len(sheet_handler.get_all_data_with_headers()) - start_row + 1)
|
num_to_process = args.limit or (len(sheet_handler.get_all_data_with_headers()) - start_row + 1)
|
||||||
data_processor.process_rows_sequentially(
|
data_processor.process_rows_sequentially(
|
||||||
@@ -216,7 +216,6 @@ def main():
|
|||||||
process_website_steps='web' in steps_to_run_set,
|
process_website_steps='web' in steps_to_run_set,
|
||||||
process_ml_steps='ml_predict' in steps_to_run_set
|
process_ml_steps='ml_predict' in steps_to_run_set
|
||||||
)
|
)
|
||||||
# ... (usw. für alle anderen Modi)
|
|
||||||
elif selected_mode == "reclassify_branches":
|
elif selected_mode == "reclassify_branches":
|
||||||
data_processor.reclassify_all_branches(start_sheet_row=args.start_sheet_row, limit=args.limit)
|
data_processor.reclassify_all_branches(start_sheet_row=args.start_sheet_row, limit=args.limit)
|
||||||
elif selected_mode == "alignment":
|
elif selected_mode == "alignment":
|
||||||
|
|||||||
Reference in New Issue
Block a user