diff --git a/src/pipelines/runner.py b/src/pipelines/runner.py index 7191bc5..c0c8152 100644 --- a/src/pipelines/runner.py +++ b/src/pipelines/runner.py @@ -69,16 +69,10 @@ def get_file_processing_module(client: str): if registry.is_vendor(client): from src.pipelines.vendors.shared.generic_processor import VendorProcessor - print( - f"[DEBUG ROUTING] runner.get_file_processing_module: client='{client}' is a vendor, using VendorProcessor" - ) return VendorProcessor(client) # Set active client so shared resolver can select function-level overrides. set_active_client(client) - print( - f"[DEBUG ROUTING] runner.get_file_processing_module: set_active_client('{client}'), using shared resolver shim" - ) from src.pipelines.shared import file_processing return file_processing @@ -159,13 +153,9 @@ def main(client: str = "saas", testing=False, test_params={}): # Ensure dynamic fallback resolution targets the requested client. set_active_client(client) - print( - f"[DEBUG ROUTING] runner.main: received client='{client}', set_active_client called" - ) # Get client-specific file processing module file_processing = get_file_processing_module(client) - print(f"[DEBUG ROUTING] runner.main: file_processing module = {file_processing}") logging.info(f"Using {client} pipeline") # Set up per-file logging diff --git a/src/pipelines/saas/file_processing.py b/src/pipelines/saas/file_processing.py index 58a99f3..2dc425b 100644 --- a/src/pipelines/saas/file_processing.py +++ b/src/pipelines/saas/file_processing.py @@ -194,9 +194,6 @@ def run_one_to_one_prompts( client_name = get_active_client() client_prompts_path = config.CLIENT_PROMPTS_MAP.get(client_name) client_full_context_fields = None - print( - f"[DEBUG ROUTING] run_one_to_one_prompts: active_client='{client_name}', client_prompts_path={client_prompts_path}" - ) if client_prompts_path: client_fields = FieldSet( @@ -207,17 +204,11 @@ def run_one_to_one_prompts( smart_chunked = client_fields.filter(field_type="smart_chunked") if smart_chunked.contains_fields(): one_to_one_fields = one_to_one_fields.combine(smart_chunked) - print( - f"[DEBUG ROUTING] run_one_to_one_prompts: combined {len(smart_chunked.fields)} smart_chunked client fields into HSC: {[f.field_name for f in smart_chunked.fields]}" - ) # full_context fields (e.g. Clover's 12 fields) are extracted separately after HSC full_context = client_fields.filter(field_type="full_context") if full_context.contains_fields(): client_full_context_fields = full_context - print( - f"[DEBUG ROUTING] run_one_to_one_prompts: queued {len(full_context.fields)} full_context client fields for extraction: {[f.field_name for f in full_context.fields]}" - ) logging.info( f"Loaded {len(client_fields.fields)} client-specific fields for {client_name}" @@ -264,9 +255,6 @@ def run_one_to_one_prompts( ################## RUN CLIENT FULL-CONTEXT FIELDS ################## # Client-specific full_context fields (e.g. Clover's 12 audit/filing/CA fields) if client_full_context_fields is not None: - print( - f"[DEBUG ROUTING] run_one_to_one_prompts: extracting {len(client_full_context_fields.fields)} full_context fields for '{client_name}'" - ) with timing_utils.timed_block( f"one_to_one.{client_name}_full_context", context=filename ): @@ -277,9 +265,6 @@ def run_one_to_one_prompts( usage_prefix=client_name.upper(), constants=constants, ) - print( - f"[DEBUG ROUTING] run_one_to_one_prompts: full_context extraction complete, got {len(fc_answers)} answers: {list(fc_answers.keys())}" - ) one_to_one_results.update(fc_answers) ################## DERIVE CLIENT-SPECIFIC FIELDS ################## @@ -290,9 +275,6 @@ def run_one_to_one_prompts( one_to_one_results["OFFSET_INDICATOR"] = "Y" else: one_to_one_results["OFFSET_INDICATOR"] = "N" - print( - f"[DEBUG ROUTING] run_one_to_one_prompts: OFFSET_TERM='{offset_term[:80]}...', derived OFFSET_INDICATOR='{one_to_one_results['OFFSET_INDICATOR']}'" - ) ################## RUN PROVIDER INFO ################## if run_provider_info: diff --git a/src/pipelines/saas/main.py b/src/pipelines/saas/main.py index a24984a..9d79c3c 100644 --- a/src/pipelines/saas/main.py +++ b/src/pipelines/saas/main.py @@ -19,9 +19,6 @@ def _resolve_client() -> str: def main(testing=False, test_params={}): client = _resolve_client() - print( - f"[DEBUG ROUTING] main.py: resolved client='{client}' from config.CLIENT={config.CLIENT}, delegating to runner.main()" - ) return runner.main(client=client, testing=testing, test_params=test_params) diff --git a/src/pipelines/shared/file_processing.py b/src/pipelines/shared/file_processing.py index 8477705..750b8a2 100644 --- a/src/pipelines/shared/file_processing.py +++ b/src/pipelines/shared/file_processing.py @@ -39,14 +39,7 @@ class ClientResolver: if client_name != "saas": client_module = cls.load_module(cls.get_client_module_name(client_name)) if client_module is not None and hasattr(client_module, name): - print( - f"[DEBUG ROUTING] file_processing resolver: '{name}' → client '{client_name}' override" - ) return getattr(client_module, name) - else: - print( - f"[DEBUG ROUTING] file_processing resolver: '{name}' → SaaS fallthrough (client='{client_name}', no override found)" - ) return getattr(saas_module, name) diff --git a/src/pipelines/shared/prompts/prompt_calls.py b/src/pipelines/shared/prompts/prompt_calls.py index c08431d..52bdc32 100644 --- a/src/pipelines/shared/prompts/prompt_calls.py +++ b/src/pipelines/shared/prompts/prompt_calls.py @@ -39,14 +39,7 @@ class ClientResolver: if client_name != "saas": client_module = cls.load_module(cls.get_client_module_name(client_name)) if client_module is not None and hasattr(client_module, name): - print( - f"[DEBUG ROUTING] prompt_calls resolver: '{name}' → client '{client_name}' override" - ) return getattr(client_module, name) - else: - print( - f"[DEBUG ROUTING] prompt_calls resolver: '{name}' → SaaS fallthrough (client='{client_name}', no override found)" - ) return getattr(saas_module, name)