Fix Python

This commit is contained in:
Alexey Milovidov 2020-07-16 06:56:46 +03:00
parent 126a94ab69
commit b0b0690e1c

View File

@ -1119,7 +1119,7 @@ def test_kafka_virtual_columns(kafka_cluster):
result = ''
while True:
result += instance.query('SELECT _key, key, _topic, value, _offset, _partition, _timestamp = 0 ? '0000-00-00 00:00:00' : toString(_timestamp) AS _timestamp FROM test.kafka', ignore_error=True)
result += instance.query('''SELECT _key, key, _topic, value, _offset, _partition, _timestamp = 0 ? '0000-00-00 00:00:00' : toString(_timestamp) AS _timestamp FROM test.kafka''', ignore_error=True)
if kafka_check_result(result, False, 'test_kafka_virtual1.reference'):
break