justin/new-site
1
0
Fork 0
Code Issues Pull requests Projects Releases Packages Wiki Activity Actions

Fix: add batch_id + engagement columns to job_server PG query

Browse source 
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) <noreply@anthropic.com>
This commit is contained in:
justin 2026-04-29 01:35:56 -05:00
parent e49efb7207
commit 314a711e95
1 changed files with 4 additions and 2 deletions
Download patch file Download diff file Expand all files Collapse all files

6
scripts/workers/job_server.py
View file

@ -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,),