thevar1able/ClickHouse
1
0
Fork 0
mirror of https://github.com/ClickHouse/ClickHouse.git synced 2024-11-27 01:51:59 +00:00
Code Issues Packages Projects Releases Wiki Activity

Fixing 00964_live_view_watch_events_heartbeat.py test to try to make it consistent.

Browse Source
This commit is contained in:
Vitaliy Zakaznikov 2020-04-18 20:28:51 -04:00
parent 398ed4d9c2
commit 8f3b14ab22
1 changed files with 8 additions and 6 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

14
tests/queries/0_stateless/00964_live_view_watch_events_heartbeat.py
View File

@ -23,7 +23,7 @@ with client(name='client1>', log=log) as client1, client(name='client2>', log=lo
client1.send('DROP TABLE IF EXISTS test.lv')
client1.expect(prompt)
client1.send(' DROP TABLE IF EXISTS test.mt')
client1.send('DROP TABLE IF EXISTS test.mt')
client1.expect(prompt)
client1.send('SET live_view_heartbeat_interval=1')
client1.expect(prompt)
@ -31,14 +31,16 @@ with client(name='client1>', log=log) as client1, client(name='client2>', log=lo
client1.expect(prompt)
client1.send('CREATE LIVE VIEW test.lv WITH TIMEOUT AS SELECT sum(a) FROM test.mt')
client1.expect(prompt)
client1.send('WATCH test.lv EVENTS')
client1.send('WATCH test.lv EVENTS FORMAT CSV')
client1.expect('Progress: 1.00 rows.*\)')
client2.send('INSERT INTO test.mt VALUES (1)')
client1.expect('1.*' + end_of_block)
client2.expect(prompt)
client1.expect('Progress: 2.00 rows.*\)')
client2.send('INSERT INTO test.mt VALUES (2),(3)')
client1.expect('[23].*' + end_of_block)
client1.expect('Progress: [23]\.00 rows.*\)')
client2.expect(prompt)
client1.expect('Progress: 3.00 rows.*\)')
# wait for heartbeat
client1.expect('Progress: [23]\.00 rows.*\)')
client1.expect('Progress: 3.00 rows.*\)')
# send Ctrl-C
client1.send('\x03', eol='')
match = client1.expect('(%s)|([#\$] )' % prompt)