CCM-12616: fix MESH lambda publishing events with null fields

Author: simonlabarere

lambdas/mesh-acknowledge/mesh_acknowledge/events.py

@@ -46,7 +46,7 @@ def publish_acknowledged_event(
 
     try:
         acknowledged_event = {
-            **incoming_event.model_dump(),
+            **incoming_event.model_dump(exclude_none=True),
             'id': str(uuid4()),
             'time': now,
             'recordedtime': now,

lambdas/mesh-download/mesh_download/__tests__/test_processor.py

@@ -163,6 +163,12 @@ def test_process_sqs_message_success(self, mock_datetime):
         assert published_event['subject'] == 'customer/00000000-0000-0000-0000-000000000000/recipient/00000000-0000-0000-0000-000000000000'
         assert published_event['time'] == '2025-11-19T15:30:45+00:00'
         assert 'id' in published_event
+        assert 'tracestate' not in published_event
+        assert 'partitionkey' not in published_event
+        assert 'sequence' not in published_event
+        assert 'dataclassification' not in published_event
+        assert 'dataregulation' not in published_event
+        assert 'datacategory' not in published_event
 
         # Verify CloudEvent data payload
         event_data = published_event['data']

lambdas/mesh-download/mesh_download/processor.py

@@ -110,7 +110,7 @@ def _publish_downloaded_event(self, incoming_event, message_uri):
         now = datetime.now(timezone.utc).isoformat()
 
         cloud_event = {
-            **incoming_event.model_dump(),
+            **incoming_event.model_dump(exclude_none=True),
             'id': str(uuid4()),
             'time': now,
             'recordedtime': now,

utils/py-utils/dl_utils/__init__.py

@@ -4,7 +4,6 @@
 """
 
 from .event_publisher import EventPublisher
-from . import models
 
 from .mesh_config import (
     BaseMeshConfig,

utils/py-utils/dl_utils/event_publisher.py

@@ -11,7 +11,6 @@
 import boto3
 from botocore.exceptions import ClientError
 from pydantic import ValidationError
-from .models import CloudEvent
 
 
 DlqReason = Literal['INVALID_EVENT', 'EVENTBRIDGE_FAILURE']