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 11:25:34 +08:00
parent 2faf995ceb
commit 0ab25ab746
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/sql.py
View File

@ -338,7 +338,7 @@ class TDSql:
return self.queryRows return self.queryRows
def checkRows(self, expectedRows): def checkRows(self, expectedRows):
self.checkEqual(self.queryRows, expectedRows) return self.checkEqual(self.queryRows, expectedRows)
# if self.queryRows == expectedRows: # if self.queryRows == expectedRows:
# tdLog.info("sql:%s, queryRows:%d == expect:%d" % (self.sql, self.queryRows, expectedRows)) # tdLog.info("sql:%s, queryRows:%d == expect:%d" % (self.sql, self.queryRows, expectedRows))
# return True # return True
@ -644,10 +644,10 @@ class TDSql:
def checkEqual(self, elm, expect_elm): def checkEqual(self, elm, expect_elm):
if elm == expect_elm: if elm == expect_elm:
tdLog.info("sql:%s, elm:%s == expect_elm:%s" % (self.sql, elm, expect_elm)) tdLog.info("sql:%s, elm:%s == expect_elm:%s" % (self.sql, elm, expect_elm))
return return True
if self.__check_equal(elm, expect_elm): if self.__check_equal(elm, expect_elm):
tdLog.info("sql:%s, elm:%s == expect_elm:%s" % (self.sql, elm, expect_elm)) tdLog.info("sql:%s, elm:%s == expect_elm:%s" % (self.sql, elm, expect_elm))
return return True
self.print_error_frame_info(elm, expect_elm) self.print_error_frame_info(elm, expect_elm)
def checkNotEqual(self, elm, expect_elm): def checkNotEqual(self, elm, expect_elm):