Remove debug routing print statements
Strip all [DEBUG ROUTING] print statements added for E2E verification.
Cherry-pick the previous commit (5e143c10) to restore them for testing.
This commit is contained in:
@@ -69,16 +69,10 @@ def get_file_processing_module(client: str):
|
|||||||
if registry.is_vendor(client):
|
if registry.is_vendor(client):
|
||||||
from src.pipelines.vendors.shared.generic_processor import VendorProcessor
|
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)
|
return VendorProcessor(client)
|
||||||
|
|
||||||
# Set active client so shared resolver can select function-level overrides.
|
# Set active client so shared resolver can select function-level overrides.
|
||||||
set_active_client(client)
|
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
|
from src.pipelines.shared import file_processing
|
||||||
|
|
||||||
return 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.
|
# Ensure dynamic fallback resolution targets the requested client.
|
||||||
set_active_client(client)
|
set_active_client(client)
|
||||||
print(
|
|
||||||
f"[DEBUG ROUTING] runner.main: received client='{client}', set_active_client called"
|
|
||||||
)
|
|
||||||
|
|
||||||
# Get client-specific file processing module
|
# Get client-specific file processing module
|
||||||
file_processing = get_file_processing_module(client)
|
file_processing = get_file_processing_module(client)
|
||||||
print(f"[DEBUG ROUTING] runner.main: file_processing module = {file_processing}")
|
|
||||||
logging.info(f"Using {client} pipeline")
|
logging.info(f"Using {client} pipeline")
|
||||||
|
|
||||||
# Set up per-file logging
|
# Set up per-file logging
|
||||||
|
|||||||
@@ -194,9 +194,6 @@ def run_one_to_one_prompts(
|
|||||||
client_name = get_active_client()
|
client_name = get_active_client()
|
||||||
client_prompts_path = config.CLIENT_PROMPTS_MAP.get(client_name)
|
client_prompts_path = config.CLIENT_PROMPTS_MAP.get(client_name)
|
||||||
client_full_context_fields = None
|
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:
|
if client_prompts_path:
|
||||||
client_fields = FieldSet(
|
client_fields = FieldSet(
|
||||||
@@ -207,17 +204,11 @@ def run_one_to_one_prompts(
|
|||||||
smart_chunked = client_fields.filter(field_type="smart_chunked")
|
smart_chunked = client_fields.filter(field_type="smart_chunked")
|
||||||
if smart_chunked.contains_fields():
|
if smart_chunked.contains_fields():
|
||||||
one_to_one_fields = one_to_one_fields.combine(smart_chunked)
|
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 fields (e.g. Clover's 12 fields) are extracted separately after HSC
|
||||||
full_context = client_fields.filter(field_type="full_context")
|
full_context = client_fields.filter(field_type="full_context")
|
||||||
if full_context.contains_fields():
|
if full_context.contains_fields():
|
||||||
client_full_context_fields = full_context
|
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(
|
logging.info(
|
||||||
f"Loaded {len(client_fields.fields)} client-specific fields for {client_name}"
|
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 ##################
|
################## RUN CLIENT FULL-CONTEXT FIELDS ##################
|
||||||
# Client-specific full_context fields (e.g. Clover's 12 audit/filing/CA fields)
|
# Client-specific full_context fields (e.g. Clover's 12 audit/filing/CA fields)
|
||||||
if client_full_context_fields is not None:
|
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(
|
with timing_utils.timed_block(
|
||||||
f"one_to_one.{client_name}_full_context", context=filename
|
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(),
|
usage_prefix=client_name.upper(),
|
||||||
constants=constants,
|
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)
|
one_to_one_results.update(fc_answers)
|
||||||
|
|
||||||
################## DERIVE CLIENT-SPECIFIC FIELDS ##################
|
################## DERIVE CLIENT-SPECIFIC FIELDS ##################
|
||||||
@@ -290,9 +275,6 @@ def run_one_to_one_prompts(
|
|||||||
one_to_one_results["OFFSET_INDICATOR"] = "Y"
|
one_to_one_results["OFFSET_INDICATOR"] = "Y"
|
||||||
else:
|
else:
|
||||||
one_to_one_results["OFFSET_INDICATOR"] = "N"
|
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 ##################
|
################## RUN PROVIDER INFO ##################
|
||||||
if run_provider_info:
|
if run_provider_info:
|
||||||
|
|||||||
@@ -19,9 +19,6 @@ def _resolve_client() -> str:
|
|||||||
|
|
||||||
def main(testing=False, test_params={}):
|
def main(testing=False, test_params={}):
|
||||||
client = _resolve_client()
|
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)
|
return runner.main(client=client, testing=testing, test_params=test_params)
|
||||||
|
|
||||||
|
|
||||||
|
|||||||
@@ -39,14 +39,7 @@ class ClientResolver:
|
|||||||
if client_name != "saas":
|
if client_name != "saas":
|
||||||
client_module = cls.load_module(cls.get_client_module_name(client_name))
|
client_module = cls.load_module(cls.get_client_module_name(client_name))
|
||||||
if client_module is not None and hasattr(client_module, 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)
|
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)
|
return getattr(saas_module, name)
|
||||||
|
|
||||||
|
|||||||
@@ -39,14 +39,7 @@ class ClientResolver:
|
|||||||
if client_name != "saas":
|
if client_name != "saas":
|
||||||
client_module = cls.load_module(cls.get_client_module_name(client_name))
|
client_module = cls.load_module(cls.get_client_module_name(client_name))
|
||||||
if client_module is not None and hasattr(client_module, 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)
|
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)
|
return getattr(saas_module, name)
|
||||||
|
|
||||||
|
|||||||
Reference in New Issue
Block a user