feat(etl): FTRS-1992 Fixing consumer

nsindhu26 · nsindhu26 · commit 4ace67e59a7c · 2026-01-07T11:08:18.000Z
diff --git a/services/etl-ods/tests/unit/test_consumer.py b/services/etl-ods/tests/unit/test_consumer.py
@@ -191,7 +191,7 @@ def test_process_message_and_send_request_success(
 
     record = {
         "messageId": "1",
-        "body": '"{\\"path\\": \\"uuid\\", \\"body\\": {\\"name\\": \\"Organization Name\\"}}"',
+        "body": '{"path": "uuid", "body": {"name": "Organization Name"}}',
     }
 
     process_message_and_send_request(record)
@@ -337,10 +337,10 @@ def test_process_message_and_send_request_with_string_body_and_correlation_id(
         json=mock_response,
     )
 
-    # Simulate SQS message format with double-encoded JSON and correlation_id
+    # Simulate SQS message format with single-encoded JSON and correlation_id
     record = {
         "messageId": "msg-123",
-        "body": '"{\\"path\\": \\"test-uuid-123\\", \\"body\\": {\\"name\\": \\"Test Org\\"}, \\"correlation_id\\": \\"corr-id-456\\"}"',
+        "body": '{"path": "test-uuid-123", "body": {"name": "Test Org"}, "correlation_id": "corr-id-456"}',
     }
 
     process_message_and_send_request(record)

Original file line number	Diff line number	Diff line change
`@@ -191,7 +191,7 @@ def test_process_message_and_send_request_success(`
`191`	`191`
`192`	`192`	`record = {`
`193`	`193`	`"messageId": "1",`
`194`		`- "body": '"{\\"path\\": \\"uuid\\", \\"body\\": {\\"name\\": \\"Organization Name\\"}}"',`
	`194`	`+ "body": '{"path": "uuid", "body": {"name": "Organization Name"}}',`
`195`	`195`	`}`
`196`	`196`
`197`	`197`	`process_message_and_send_request(record)`
`@@ -337,10 +337,10 @@ def test_process_message_and_send_request_with_string_body_and_correlation_id(`
`337`	`337`	`json=mock_response,`
`338`	`338`	`)`
`339`	`339`
`340`		`- # Simulate SQS message format with double-encoded JSON and correlation_id`
	`340`	`+ # Simulate SQS message format with single-encoded JSON and correlation_id`
`341`	`341`	`record = {`
`342`	`342`	`"messageId": "msg-123",`
`343`		`- "body": '"{\\"path\\": \\"test-uuid-123\\", \\"body\\": {\\"name\\": \\"Test Org\\"}, \\"correlation_id\\": \\"corr-id-456\\"}"',`
	`343`	`+ "body": '{"path": "test-uuid-123", "body": {"name": "Test Org"}, "correlation_id": "corr-id-456"}',`
`344`	`344`	`}`
`345`	`345`
`346`	`346`	`process_message_and_send_request(record)`