jacob-mathison/doczyai-pipelines
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Activity

Remove debug routing print statements

Browse Source 
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:
ppanchigar
2026-04-14 10:42:10 -05:00
parent 5e143c10f0
commit 63f32c418c
5 changed files with 0 additions and 45 deletions
Download Patch File Download Diff File Expand all files Collapse all files
src/pipelines/runner.py
-10
View File
@@ -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
src/pipelines/saas/file_processing.py
-18
View File
@@ -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:
src/pipelines/saas/main.py
-3
View File
@@ -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)
src/pipelines/shared/file_processing.py
-7
View File
@@ -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)
src/pipelines/shared/prompts/prompt_calls.py
-7
View File
@@ -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)