(open_message, **kwargs)
| 2467 | self._pushToArray(messages_history, m) |
| 2468 | |
| 2469 | def openCB(open_message, **kwargs): |
| 2470 | self._pushToArray(messages_history, open_message) |
| 2471 | if not open_message.status.hasError: |
| 2472 | if max_length == 0: |
| 2473 | closeFid(open_message.tid, open_message.payload.fid) |
| 2474 | callback(( file_obj, open_message.payload.file_attributes, 0 )) |
| 2475 | else: |
| 2476 | if show_progress and max_length > 0: |
| 2477 | tqdm_kwargs.setdefault("total", max_length) |
| 2478 | tqdm_kwargs.setdefault("unit", "B") |
| 2479 | tqdm_kwargs.setdefault("unit_scale", True) |
| 2480 | tqdm_kwargs.setdefault("unit_divisor", 1024) |
| 2481 | tqdm_kwargs.setdefault("desc", f"Downloading {path}") |
| 2482 | self.pbar = tqdm(**tqdm_kwargs) |
| 2483 | sendRead(open_message.tid, open_message.payload.fid, starting_offset, open_message.payload.file_attributes, 0, max_length) |
| 2484 | else: |
| 2485 | errback(OperationFailure('Failed to retrieve %s on %s: Unable to open file' % ( path, service_name ), messages_history)) |
| 2486 | |
| 2487 | def sendRead(tid, fid, offset, file_attributes, read_len, remaining_len): |
| 2488 | read_count = self.max_raw_size - 2 |
nothing calls this directly
no test coverage detected