junte/Model
1
0
Fork 0
mirror of https://github.com/Hestia-Homes/Model.git synced 2026-06-30 13:10:47 +00:00
Code Issues Projects Releases Packages Wiki Activity Actions

send message to address2uprn

Browse source
This commit is contained in:
Jun-te Kim 2026-02-16 14:16:57 +00:00
parent 0a87ba786c
commit 12b9966982
1 changed files with 6 additions and 14 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

20
backend/postcode_splitter/main.py
View file

@ -101,14 +101,6 @@ def create_batch_and_send_to_address2uprn(
""" """
Create a batch DataFrame, upload to S3, create subtask, and send to address2UPRN queue. Create a batch DataFrame, upload to S3, create subtask, and send to address2UPRN queue.
Args:
batch_rows: List of row dictionaries for this batch
task_id: The parent task ID
subtask_interface: SubTaskInterface instance
bucket_name: S3 bucket name
Returns:
The created batch subtask ID
""" """
# Upload batch to S3 # Upload batch to S3
@ -125,12 +117,12 @@ def create_batch_and_send_to_address2uprn(
logger.info(f"Created batch subtask {created_batch_sub_task_id}") logger.info(f"Created batch subtask {created_batch_sub_task_id}")
# # Send message with S3 reference # Send message with S3 reference
# send_to_address2uprn_queue( send_to_address2uprn_queue(
# task_id=str(task_id), task_id=str(task_id),
# sub_task_id=str(created_batch_sub_task_id), sub_task_id=str(created_batch_sub_task_id),
# s3_uri=s3_uri, s3_uri=s3_uri,
# ) )
return created_batch_sub_task_id return created_batch_sub_task_id