This commit is contained in:
2025-06-27 09:01:04 +00:00
parent d16318a9ab
commit 8b5b4d6be0

View File

@@ -2881,14 +2881,11 @@ class DataProcessor:
"justification": error[:500]}
return {"row_num": row_num, "result": result, "error": error}
def process_branch_batch(
self,
start_sheet_row=None,
end_sheet_row=None,
limit=None):
def process_branch_batch(self, start_sheet_row=None, end_sheet_row=None, limit=None):
"""
Batch-Prozess NUR fuer Brancheneinschaetzung.
"""
global ALLOWED_TARGET_BRANCHES
self.logger.info(
f"Starte Brancheneinschaetzung (Parallel Batch). Bereich: {start_sheet_row if start_sheet_row else 'Start'}-{end_sheet_row if end_sheet_row else 'Ende'}, Limit: {limit if limit else 'Unbegrenzt'}")
if not ALLOWED_TARGET_BRANCHES:
@@ -2964,7 +2961,6 @@ class DataProcessor:
processed_tasks_count = 0 # Zählt Tasks, die tatsächlich verarbeitet wurden
skipped_count = 0
global ALLOWED_TARGET_BRANCHES
if not ALLOWED_TARGET_BRANCHES:
load_target_schema()
if not ALLOWED_TARGET_BRANCHES: