____________________________ test_copy_simple[True] ____________________________
[gw0] linux -- Python 3.8.10 /usr/bin/python3
started_cluster = <helpers.cluster.ClickHouseCluster object at 0x7f9093fcb460>
use_sample_offset = True
@pytest.mark.parametrize(('use_sample_offset'), [False, True])
def test_copy_simple(started_cluster, use_sample_offset):
if use_sample_offset:
> execute_task(started_cluster, Task1(started_cluster), ['--experimental-use-sample-offset', '1'])
test_cluster_copier/test.py:387:
_ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _
test_cluster_copier/test.py:377: in execute_task
task.check()
_ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _
self = <test_cluster_copier.test.Task1 object at 0x7f9093dd2f40>
def check(self):
assert self.cluster.instances['s0_0_0'].query("SELECT count() FROM hits_all").strip() == "1002"
> assert self.cluster.instances['s1_0_0'].query("SELECT count() FROM hits_all").strip() == "1002"
E AssertionError: assert '927' == '1002'
E - 1002
E + 927
test_cluster_copier/test.py:109: AssertionError
