(
self,
request_type,
call_args,
coordinator,
future,
on_done_before_calls,
on_done_after_calls,
)
| 800 | return make_request_args |
| 801 | |
| 802 | def _get_make_request_args_get_object( |
| 803 | self, |
| 804 | request_type, |
| 805 | call_args, |
| 806 | coordinator, |
| 807 | future, |
| 808 | on_done_before_calls, |
| 809 | on_done_after_calls, |
| 810 | ): |
| 811 | recv_filepath = None |
| 812 | on_body = None |
| 813 | checksum_config = awscrt.s3.S3ChecksumConfig(validate_response=True) |
| 814 | if isinstance(call_args.fileobj, str): |
| 815 | final_filepath = call_args.fileobj |
| 816 | recv_filepath = self._os_utils.get_temp_filename(final_filepath) |
| 817 | on_done_before_calls.append( |
| 818 | RenameTempFileHandler( |
| 819 | coordinator, final_filepath, recv_filepath, self._os_utils |
| 820 | ) |
| 821 | ) |
| 822 | else: |
| 823 | on_body = OnBodyFileObjWriter(call_args.fileobj) |
| 824 | |
| 825 | make_request_args = self._default_get_make_request_args( |
| 826 | request_type=request_type, |
| 827 | call_args=call_args, |
| 828 | coordinator=coordinator, |
| 829 | future=future, |
| 830 | on_done_before_calls=on_done_before_calls, |
| 831 | on_done_after_calls=on_done_after_calls, |
| 832 | ) |
| 833 | make_request_args['recv_filepath'] = recv_filepath |
| 834 | make_request_args['on_body'] = on_body |
| 835 | make_request_args['checksum_config'] = checksum_config |
| 836 | return make_request_args |
| 837 | |
| 838 | def _default_get_make_request_args( |
| 839 | self, |
nothing calls this directly
no test coverage detected