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

tetst:check stream task status in common.py

This commit is contained in:
chenhaoran 2024-08-29 15:42:47 +08:00
parent 0ab25ab746
commit 8b3aca49e3
1 changed files with 3 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
tests/pytest/util/common.py
View File

@ -997,8 +997,8 @@ class TDCom:
second_number = int(match.group(3)) # The second number inside the brackets
# Compare the extracted numbers and return the result
return first_number == second_number
if first_number >= second_number-5 and first_number <= second_number:
return True
# If no match was found, or the pattern does not match the expected format, return False
return False
@ -1035,7 +1035,7 @@ class TDCom:
result_task_history_rows = tdSql.query(sql_task_history)
tdLog.notice(f"Try to check stream status, check times: {checktimes} and stream task list[{check_stream_success}]")
# print(f"result_task_status:{result_task_status},result_task_history:{result_task_history},result_task_alll:{result_task_alll}")
print(f"result_task_status:{result_task_status},result_task_history:{result_task_history},result_task_alll:{result_task_alll}")
if result_task_status_rows == 1 and result_task_status ==[('ready',)] :
if result_task_history_rows == 1 and result_task_history == [(None,)] :
for vgroup_num in range(vgroups):