(*args: Any, **kwargs: Any)
| 1557 | |
| 1558 | |
| 1559 | def send_command_retry(*args: Any, **kwargs: Any) -> Tuple[int, bytes, str]: |
| 1560 | while True: |
| 1561 | try: |
| 1562 | return send_command(*args, **kwargs) |
| 1563 | except Exception as e: |
| 1564 | # If our librados instance has not reached state 'connected' |
| 1565 | # yet, we'll see an exception like this and retry |
| 1566 | if ('get_command_descriptions' in str(e) and |
| 1567 | 'object in state configuring' in str(e)): |
| 1568 | continue |
| 1569 | else: |
| 1570 | raise |
| 1571 | |
| 1572 | |
| 1573 | def send_command(cluster, |
no test coverage detected