Model/infrastructure/address2uprn_queue_client.py
2026-05-20 13:21:11 +00:00

20 lines
454 B
Python

from uuid import UUID
from infrastructure.sqs_client import SqsClient
class Address2UprnQueueClient(SqsClient):
def publish(
self,
*,
parent_task_id: UUID,
child_subtask_id: UUID,
s3_uri: str,
) -> str:
return self.send(
{
"task_id": str(parent_task_id),
"sub_task_id": str(child_subtask_id),
"s3_uri": s3_uri,
}
)