From 84191ad8a4a234396d7700cd2b1610f488ef35c9 Mon Sep 17 00:00:00 2001 From: Hillel Arnold Date: Tue, 6 Oct 2026 14:22:12 -0400 Subject: [PATCH 1/2] add logging --- src/transformer.py | 10 ++++++++++ 1 file changed, 10 insertions(+) diff --git a/src/transformer.py b/src/transformer.py index b5a070e..9664d0c 100644 --- a/src/transformer.py +++ b/src/transformer.py @@ -18,6 +18,9 @@ SourceAgentPerson, SourceArchivalObject, SourceResource, SourceSubject) +logger = logging.getLogger() +logger.setLevel(getenv('LOGGING_LEVEL', logging.INFO)) + def get_config(environment, aws_region, service_name): """Fetch config values from SSM Parameter Store by path.""" @@ -194,17 +197,23 @@ def send_error_message(self, exception, object_type, object_id): }) def run(self, object_type, data): + logging.debug(f"Running transform for {object_type} {data['uri']}") try: from_resource, mapping, schema_name = self.get_mapping_classes( object_type) transformed = self.get_transformed_object( data, from_resource, mapping) + logging.debug(f"Object {data['uri']} transformed") transformed['online_pending'] = self.get_online_pending( data.get("instances", []), transformed.get("online", False)) + logging.debug(f"Online pending set for object {data['uri']}") self.validate_transformed(transformed, schema_name) + logging.debug(f"Transformed object {data['uri']} validated") self.send_success_message(transformed, object_type) + logging.info(f"Transformation for {object_type} {data['uri']} complete") except Exception as e: + logging.error(e) self.send_error_message( e, object_type, identifier_from_uri( data['uri'])) @@ -212,6 +221,7 @@ def run(self, object_type, data): def lambda_handler(event, context): """Process SQS batch.""" + logger.info("Message batch received.") transformer = Transformer() From 2ffbb5cf732ce7a631d805f0d48615be2003cb88 Mon Sep 17 00:00:00 2001 From: Hillel Arnold Date: Tue, 6 Oct 2026 14:24:10 -0400 Subject: [PATCH 2/2] update tests --- tests/test_transformer.py | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/tests/test_transformer.py b/tests/test_transformer.py index 224db8e..4a8bc54 100644 --- a/tests/test_transformer.py +++ b/tests/test_transformer.py @@ -92,11 +92,11 @@ def test_run( mock_online_pending.return_value = False mock_validate.return_value = True - self.transformer.run('agent_person', {}) + self.transformer.run('agent_person', {"uri": "54321"}) mock_mapping.assert_called_once_with('agent_person') mock_get_transformed.assert_called_once_with( - {}, SourceAgentPerson, SourceAgentPersonToAgent) + {"uri": "54321"}, SourceAgentPerson, SourceAgentPersonToAgent) mock_validate.assert_called_once_with( transformed_object, self.transformer.config['SCHEMA_AGENT']) mock_success_message.assert_called_once_with(