(self)
| 981 | pass |
| 982 | |
| 983 | def disconnect_connection_pools(self): |
| 984 | for node in self.get_nodes(): |
| 985 | if node.redis_connection: |
| 986 | try: |
| 987 | node.redis_connection.connection_pool.disconnect() |
| 988 | except OSError: |
| 989 | # Client was already disconnected. do nothing |
| 990 | pass |
| 991 | |
| 992 | def on_connect(self, connection): |
| 993 | """ |