(self, params, bundle)
| 195 | yield tf |
| 196 | |
| 197 | def _upload_to_s3(self, params, bundle): |
| 198 | size_remaining = self._bundle_size(bundle) |
| 199 | if size_remaining < MULTIPART_LIMIT: |
| 200 | return self.s3.put_object( |
| 201 | Bucket=params.bucket, Key=params.key, Body=bundle |
| 202 | ) |
| 203 | else: |
| 204 | return self._multipart_upload_to_s3(params, bundle, size_remaining) |
| 205 | |
| 206 | def _bundle_size(self, bundle): |
| 207 | bundle.seek(0, 2) |