diff --git a/cdk/wo_stack.py b/cdk/wo_stack.py index 7d6bbc0..0f5ee16 100644 --- a/cdk/wo_stack.py +++ b/cdk/wo_stack.py @@ -750,14 +750,12 @@ def _add_shoc_webhook_emitter(stack, work_orders_table, comments_table, alarm_to shoc_emitter_rejected_queue.grant_send_messages(shoc_emitter) # ------------------------------------------------------------------ - # SHIPS DARK: both event source mappings deploy with enabled=False, - # deliberately. The full stack (Lambda, queues, alarms, secret, - # rotation) deploys and is testable with zero deliveries while SHOC - # has no receiver, so our merge cadence never depends on Luby's. - # Activation is a one-line enabled=True PR gated on the SHOC receiver - # passing the shared HMAC test vectors (plan Phase 3). LATEST start - # position => no historical flood at activation; SHOC loads history - # via the procurement read API instead. + # ACTIVATED (enabled=True) 2026-XX-XX after SHOC's receiver passed the + # shared HMAC test vectors. Shipped DARK originally (enabled=False) so the + # stack could deploy and be tested with zero deliveries while SHOC had no + # receiver; this activation PR is the deliberate one-line flip (plan Phase + # 3). LATEST start position => the feed begins now, no historical flood; + # SHOC loaded history via the procurement read API before this flip. # Ordering knobs: parallelization_factor=1, bisect_batch_on_error= # False and retry_attempts=-1 (retry until the 24h record age) are # REQUIRED for strict per-work-order in-order delivery -- a retryable @@ -775,7 +773,7 @@ def _add_shoc_webhook_emitter(stack, work_orders_table, comments_table, alarm_to max_record_age=Duration.hours(24), parallelization_factor=1, report_batch_item_failures=True, - enabled=False, + enabled=True, on_failure=lambda_event_sources.SqsDlq(shoc_emitter_failures_queue), ) ) @@ -789,7 +787,7 @@ def _add_shoc_webhook_emitter(stack, work_orders_table, comments_table, alarm_to max_record_age=Duration.hours(24), parallelization_factor=1, report_batch_item_failures=True, - enabled=False, + enabled=True, on_failure=lambda_event_sources.SqsDlq(shoc_emitter_failures_queue), ) )