in src/clients/s3_client.py [0:0]
def respond_back_with_data(self, data, headers: map, request_route: str, request_token: str,
status_code: S3_STATUS_CODES = S3_STATUS_CODES.OK_200):
"""Call S3's WriteGetObjectResponse API to return the processed object back to the original caller of get_object API."""
start_time = time.time()
try:
parsed_headers = self._parse_response_headers(headers)
LOG.debug(f"Calling s3 WriteGetObjectResponse with RequestRoute:{request_route} , headers: {parsed_headers},"
f" RequestToken: {request_token}")
self.s3.write_get_object_response(StatusCode=status_code.get_http_status_code(), Body=data, RequestRoute=request_route,
RequestToken=request_token, **parsed_headers)
except Exception as error:
LOG.error("Error occurred while calling s3 write get object response with data.", exc_info=True)
self.write_get_object_metrics.add_fault_count()
raise error
finally:
self.write_get_object_metrics.add_latency(start_time, time.time())