thevar1able/ClickHouse
1
0
Fork 0
mirror of https://github.com/ClickHouse/ClickHouse.git synced 2024-09-21 09:10:48 +00:00
Code Issues Packages Projects Releases Wiki Activity

Tests fix.

Browse Source
This commit is contained in:
Vladimir Chebotarev 2019-09-13 13:53:17 +00:00
parent 2cddcebc31
commit 4406ad1061
2 changed files with 6 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

7
dbms/tests/integration/test_storage_s3/test.py
View File

@ -23,7 +23,8 @@ def test_sophisticated_default(started_cluster):
instance = started_cluster.instances['dummy'] instance = started_cluster.instances['dummy']
instance.copy_file_to_container(os.path.join(os.path.dirname(__file__), 'test_server.py'), 'test_server.py') instance.copy_file_to_container(os.path.join(os.path.dirname(__file__), 'test_server.py'), 'test_server.py')
communication_path = '/test_sophisticated_default' communication_path = '/test_sophisticated_default'
instance.exec_in_container(['python', 'test_server.py', communication_path], detach=True) bucket = 'abc'
instance.exec_in_container(['python', 'test_server.py', communication_path, bucket], detach=True)
format = 'column1 UInt32, column2 UInt32, column3 UInt32' format = 'column1 UInt32, column2 UInt32, column3 UInt32'
values = '(1, 2, 3), (3, 2, 1), (78, 43, 45)' values = '(1, 2, 3), (3, 2, 1), (78, 43, 45)'
@ -45,7 +46,6 @@ def test_sophisticated_default(started_cluster):
assert False, 'Could not initialize mock server' + str(raw) assert False, 'Could not initialize mock server' + str(raw)
redirecting_host = localhost redirecting_host = localhost
bucket = 'abc'
def run_query(query): def run_query(query):
print('Running query "{}"...'.format(query)) print('Running query "{}"...'.format(query))
@ -117,6 +117,9 @@ def test_sophisticated_default(started_cluster):
['1', '1', '1', '1'], ['1', '1', '1', '1'],
['11', '11', '11', '1331'], ['11', '11', '11', '1331'],
] ]
# FIXME check result
# FIXME tests for multipart
finally: finally:
print('Done') print('Done')

1
dbms/tests/integration/test_storage_s3/test_server.py
View File

@ -29,6 +29,7 @@ logging.getLogger().addHandler(file_handler)
logging.getLogger().addHandler(logging.StreamHandler()) logging.getLogger().addHandler(logging.StreamHandler())
comm_path = sys.argv[1] comm_path = sys.argv[1]
bucket = sys.argv[2]
def GetFreeTCPPortsAndIP(n): def GetFreeTCPPortsAndIP(n):
result = [] result = []