From 1814c5988c151759c90e9a9807c636162a95c14d Mon Sep 17 00:00:00 2001
From: Jun-te Kim <junte.kim@mealcraft.com>
Date: Fri, 13 Feb 2026 11:05:05 +0000
Subject: [PATCH]  run on sqs

---
 .github/workflows/_build_image.yml |  2 +-
 backend/postcode_splitter/main.py  | 20 +++++++++-----------
 2 files changed, 10 insertions(+), 12 deletions(-)

diff --git a/.github/workflows/_build_image.yml b/.github/workflows/_build_image.yml
index 5e5b5155..3435c92d 100644
--- a/.github/workflows/_build_image.yml
+++ b/.github/workflows/_build_image.yml
@@ -90,7 +90,7 @@ jobs:
             temp=$(eval echo "$line")
             BUILD_ARGS="$BUILD_ARGS --build-arg $temp"
           done <<< "${{ inputs.build_args }}"
-          
+
           docker buildx build \
             --no-cache \
             --platform linux/amd64 \
diff --git a/backend/postcode_splitter/main.py b/backend/postcode_splitter/main.py
index 85dbc2da..3d0f0d8d 100644
--- a/backend/postcode_splitter/main.py
+++ b/backend/postcode_splitter/main.py
@@ -132,19 +132,17 @@ def send_to_address2uprn_queue(task_id: str, sub_task_id: str, s3_uri: str) -> s
         "s3_uri": s3_uri,
     }
 
-    # # Don't run on sqs yet
-    # response = sqs_client.send_message(
-    #     QueueUrl=queue_url,
-    #     MessageBody=json.dumps(message_body),
-    # )
+    response = sqs_client.send_message(
+        QueueUrl=queue_url,
+        MessageBody=json.dumps(message_body),
+    )
 
-    # logger.info(
-    #     f"Sent message to address2UPRN queue. "
-    #     f"Task: {task_id}, SubTask: {sub_task_id}, MessageId: {response['MessageId']}"
-    # )
+    logger.info(
+        f"Sent message to address2UPRN queue. "
+        f"Task: {task_id}, SubTask: {sub_task_id}, MessageId: {response['MessageId']}"
+    )
 
-    # return response["MessageId"]
-    return str(uuid4())
+    return response["MessageId"]
 
 
 def create_batch_and_send_to_address2uprn(