(self, *args, **options)
| 2903 | self._watching = True |
| 2904 | |
| 2905 | async def _immediate_execute_command(self, *args, **options): |
| 2906 | return await self._retry.call_with_retry( |
| 2907 | lambda: self._get_connection_and_send_command(*args, **options), |
| 2908 | self._reinitialize_on_error, |
| 2909 | with_failure_count=True, |
| 2910 | ) |
| 2911 | |
| 2912 | async def _get_connection_and_send_command(self, *args, **options): |
| 2913 | redis_node, connection = self._get_client_and_connection_for_transaction() |
no test coverage detected