Wrapper around send_request for slow requests. To be able to show progression for small requests
(self, request, labels, operation_size=0)
| 1795 | return response |
| 1796 | |
| 1797 | def send_request_with_progress(self, request, labels, operation_size=0): |
| 1798 | """Wrapper around send_request for slow requests. |
| 1799 | |
| 1800 | To be able to show progression for small requests |
| 1801 | """ |
| 1802 | if not self.config.progress_meter: |
| 1803 | info("Sending slow request, please wait...") |
| 1804 | return self.send_request(request) |
| 1805 | |
| 1806 | if 'action' not in labels: |
| 1807 | labels[u'action'] = u'request' |
| 1808 | progress = self.config.progress_class(labels, operation_size) |
| 1809 | |
| 1810 | try: |
| 1811 | response = self.send_request(request) |
| 1812 | except Exception as exc: |
| 1813 | progress.done("failed") |
| 1814 | raise |
| 1815 | |
| 1816 | progress.update(current_position=operation_size) |
| 1817 | progress.done("done") |
| 1818 | |
| 1819 | return response |
| 1820 | |
| 1821 | def send_file(self, request, stream, labels, buffer = '', throttle = 0, |
| 1822 | retries = None, offset = 0, chunk_size = -1, |
no test coverage detected