xxq250
/
homework-jianmu
1
0
Fork 0
Code Issues Pull Requests 1 Actions Packages Projects Releases Wiki Activity

test case

This commit is contained in:
factosea 2024-11-28 15:54:05 +08:00
parent c30d48a8a5
commit 41bb4a84e7
1 changed files with 4 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

7
tests/system-test/8-stream/checkpoint_info.py
View File

@ -86,7 +86,7 @@ class TDTestCase:
tdLog.debug("========restart stream========") tdLog.debug("========restart stream========")
time.sleep(10) time.sleep(10)
for i in range(5): for i in range(5):
tdSql.execute("pause stream s1") tdSql.execute("pause stream s1", 60)
time.sleep(2) time.sleep(2)
tdSql.execute("resume stream s1") tdSql.execute("resume stream s1")
def initstream(self): def initstream(self):
@ -125,11 +125,12 @@ class TDTestCase:
print("========run========") print("========run========")
self.initstream() self.initstream()
self.restart_stream() self.restart_stream()
time.sleep(60) time.sleep(5)
self.print_time_info() self.print_time_info()
self.redistribute_vnode() self.redistribute_vnode()
time.sleep(20)
self.restart_stream() self.restart_stream()
time.sleep(60) time.sleep(5)
self.print_time_info() self.print_time_info()
def stop(self): def stop(self):