diff --git a/backend/postcode_splitter/main.py b/backend/postcode_splitter/main.py index 70ecf5f1..4f63ed4b 100644 --- a/backend/postcode_splitter/main.py +++ b/backend/postcode_splitter/main.py @@ -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. - 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 @@ -125,12 +117,12 @@ def create_batch_and_send_to_address2uprn( logger.info(f"Created batch subtask {created_batch_sub_task_id}") - # # Send message with S3 reference - # send_to_address2uprn_queue( - # task_id=str(task_id), - # sub_task_id=str(created_batch_sub_task_id), - # s3_uri=s3_uri, - # ) + # Send message with S3 reference + send_to_address2uprn_queue( + task_id=str(task_id), + sub_task_id=str(created_batch_sub_task_id), + s3_uri=s3_uri, + ) return created_batch_sub_task_id