From 314a711e953998b5ad0756acc265015740043c6a Mon Sep 17 00:00:00 2001 From: justin Date: Wed, 29 Apr 2026 01:35:56 -0500 Subject: [PATCH] Fix: add batch_id + engagement columns to job_server PG query batch_id was missing from the SELECT, so order_data.batch_id was always None. This meant the batch email skip in _request_entity_intake never triggered, causing duplicate intake emails for every batch order. Co-Authored-By: Claude Opus 4.6 (1M context) --- scripts/workers/job_server.py | 6 ++++-- 1 file changed, 4 insertions(+), 2 deletions(-) diff --git a/scripts/workers/job_server.py b/scripts/workers/job_server.py index d2401da..af75a99 100644 --- a/scripts/workers/job_server.py +++ b/scripts/workers/job_server.py @@ -1001,7 +1001,7 @@ def handle_process_compliance_service(payload: dict) -> dict: cur = conn.cursor(cursor_factory=psycopg2.extras.RealDictCursor) cur.execute( """ - SELECT service_slug, telecom_entity_id, + SELECT service_slug, telecom_entity_id, batch_id, customer_email, customer_name, customer_phone, intake_data, filing_mode, form_year_override, @@ -1010,7 +1010,9 @@ def handle_process_compliance_service(payload: dict) -> dict: waive_deminimis_exemption, waive_deminimis_reason, multi_year_filings, multi_year_discount_pct, deminimis_result_is_exempt, - deminimis_estimated_contrib_cents + deminimis_estimated_contrib_cents, + engagement_esign_required, + engagement_esign_signed_at FROM compliance_orders WHERE order_number = %s """, (order_number,),