try avoiding bad file descriptor

This commit is contained in:
Antonio Andelic 2023-01-12 11:28:41 +00:00
parent 97266ccabc
commit feaad2bd43

View File

@ -107,13 +107,13 @@ def create_drop_loop(index, stop_event):
if stop_event.is_set():
return
node.query(
node.query_with_retry(
f"CREATE TABLE {table_name} (key UInt64, value UInt64) ENGINE = KeeperMap('/test') PRIMARY KEY(key);"
)
node.query(f"INSERT INTO {table_name} VALUES ({index}, {i})")
result = node.query(f"SELECT value FROM {table_name} WHERE key = {index}")
node.query_with_retry(f"INSERT INTO {table_name} VALUES ({index}, {i})")
result = node.query_with_retry(f"SELECT value FROM {table_name} WHERE key = {index}")
assert result.strip() == str(i)
node.query(f"DROP TABLE {table_name} SYNC")
node.query_with_retry(f"DROP TABLE {table_name} SYNC")
def test_create_drop_keeper_map_concurrent(started_cluster):