test: update max_delay_interval.py
This commit is contained in:
parent
e44206aaca
commit
3ae19e8e1b
|
@ -62,13 +62,13 @@ class TDTestCase:
|
|||
if self.tdCom.update and i%2 == 0:
|
||||
self.tdCom.sinsert_rows(tbname=self.ctb_name, ts_value=self.tdCom.date_time+num*self.tdCom.offset)
|
||||
self.tdCom.sinsert_rows(tbname=self.tb_name, ts_value=self.tdCom.date_time+num*self.tdCom.offset)
|
||||
if not fill_value:
|
||||
for tbname in [self.stb_stream_des_table, self.ctb_stream_des_table, self.tb_stream_des_table]:
|
||||
if tbname != self.tb_stream_des_table:
|
||||
tdSql.query(f'select wstart, {self.tdCom.stb_output_select_str} from {tbname}')
|
||||
else:
|
||||
tdSql.query(f'select wstart, {self.tdCom.tb_output_select_str} from {tbname}')
|
||||
tdSql.checkEqual(tdSql.queryRows, init_num)
|
||||
# if not fill_value:
|
||||
# for tbname in [self.stb_stream_des_table, self.ctb_stream_des_table, self.tb_stream_des_table]:
|
||||
# if tbname != self.tb_stream_des_table:
|
||||
# tdSql.query(f'select wstart, {self.tdCom.stb_output_select_str} from {tbname}')
|
||||
# else:
|
||||
# tdSql.query(f'select wstart, {self.tdCom.tb_output_select_str} from {tbname}')
|
||||
# tdSql.checkEqual(tdSql.queryRows, init_num)
|
||||
|
||||
self.tdCom.sinsert_rows(tbname=self.ctb_name, ts_value=window_close_ts-1)
|
||||
self.tdCom.sinsert_rows(tbname=self.tb_name, ts_value=window_close_ts-1)
|
||||
|
@ -149,7 +149,7 @@ class TDTestCase:
|
|||
for watermark in [None, random.randint(20, 25)]:
|
||||
self.watermark_max_delay_interval(interval=random.choice([15]), watermark=watermark, max_delay=f"{random.randint(5, 6)}s")
|
||||
for fill_value in ["NULL", "PREV", "NEXT", "LINEAR", "VALUE,1,2,3,4,5,6,7,8,9,10,11,1,2,3,4,5,6,7,8,9,10,11"]:
|
||||
self.watermark_max_delay_interval(interval=random.randint(10, 15), watermark=None, max_delay=f"{random.randint(5, 6)}s", fill_value=fill_value)
|
||||
self.watermark_max_delay_interval(interval=random.randint(10, 15), watermark=None, max_delay=f"{random.randint(5, 6)}s", fill_value=fill_value)
|
||||
|
||||
def stop(self):
|
||||
tdSql.close()
|
||||
|
|
Loading…
Reference in New Issue