:return:
(self)
| 225 | it.next() |
| 226 | |
| 227 | def _init_prepare(self): |
| 228 | """ |
| 229 | |
| 230 | :return: |
| 231 | """ |
| 232 | self.taskList = [] |
| 233 | |
| 234 | proc = Process() |
| 235 | for cmd in ['CMD_TABLE_STOP', 'CMD_TABLE_START']: |
| 236 | cmd = util.get(cmd) |
| 237 | proc.run(cmd) |
| 238 | self.rtidbClient = RtidbClient(endpoint=util.get('ENDPOINT')) |
| 239 | self.append(self.rtidbClient.drop_table) |
| 240 | self.run(failonerror=False, autoidentity=False) |
| 241 | |
| 242 | self.taskList = [] |
| 243 | self.pk = ''.join(random.sample(string.lowercase+string.digits, 20)) |
| 244 | |
| 245 | def _common_check(self, autoidentity, retStatus, logcheck): |
| 246 | """ |