(self)
| 166 | sys.stderr.write("Redis output: {}\n".format(self._get_output())) |
| 167 | |
| 168 | def _wait_for_child(self): |
| 169 | # Wait until file is available |
| 170 | r = self.client() |
| 171 | while True: |
| 172 | info = r.info('persistence') |
| 173 | if info['aof_rewrite_scheduled'] or info['aof_rewrite_in_progress']: |
| 174 | time.sleep(0.1) |
| 175 | else: |
| 176 | break |
| 177 | |
| 178 | def dump_and_reload(self, restart_process=False): |
| 179 | """ |