thevar1able/ClickHouse
1
0
Fork 0
mirror of https://github.com/ClickHouse/ClickHouse.git synced 2024-12-18 04:12:19 +00:00
Code Issues Packages Projects Releases Wiki Activity

Merge branch 'disks-and-io-sheduler' of github.com:ClickHouse/ClickHouse into disks-and-io-sheduler

Browse Source
This commit is contained in:
serxa 2023-09-06 19:30:49 +00:00
commit 2fe9a25954
1 changed files with 23 additions and 8 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

31
tests/integration/test_scheduler/test.py
View File

@ -37,9 +37,12 @@ def test_s3_disk():
def write_query(workload): def write_query(workload):
try: try:
node.query(f"insert into data select * from numbers(1e5) settings workload='{workload}'") node.query(
f"insert into data select * from numbers(1e5) settings workload='{workload}'"
)
except QueryRuntimeException: except QueryRuntimeException:
pass pass
thread1 = threading.Thread(target=write_query, args=["development"]) thread1 = threading.Thread(target=write_query, args=["development"])
thread2 = threading.Thread(target=write_query, args=["production"]) thread2 = threading.Thread(target=write_query, args=["production"])
thread3 = threading.Thread(target=write_query, args=["admin"]) thread3 = threading.Thread(target=write_query, args=["admin"])
@ -53,15 +56,21 @@ def test_s3_disk():
thread1.join() thread1.join()
assert ( assert (
node.query(f"select dequeued_requests>0 from system.scheduler where resource='network_write' and path='/prio/admin'") node.query(
f"select dequeued_requests>0 from system.scheduler where resource='network_write' and path='/prio/admin'"
)
== "1\n" == "1\n"
) )
assert ( assert (
node.query(f"select dequeued_requests>0 from system.scheduler where resource='network_write' and path='/prio/fair/dev'") node.query(
f"select dequeued_requests>0 from system.scheduler where resource='network_write' and path='/prio/fair/dev'"
)
== "1\n" == "1\n"
) )
assert ( assert (
node.query(f"select dequeued_requests>0 from system.scheduler where resource='network_write' and path='/prio/fair/prod'") node.query(
f"select dequeued_requests>0 from system.scheduler where resource='network_write' and path='/prio/fair/prod'"
)
== "1\n" == "1\n"
) )
@ -70,6 +79,7 @@ def test_s3_disk():
node.query(f"select sum(key*key) from data settings workload='{workload}'") node.query(f"select sum(key*key) from data settings workload='{workload}'")
except QueryRuntimeException: except QueryRuntimeException:
pass pass
thread1 = threading.Thread(target=read_query, args=["development"]) thread1 = threading.Thread(target=read_query, args=["development"])
thread2 = threading.Thread(target=read_query, args=["production"]) thread2 = threading.Thread(target=read_query, args=["production"])
thread3 = threading.Thread(target=read_query, args=["admin"]) thread3 = threading.Thread(target=read_query, args=["admin"])
@ -83,15 +93,20 @@ def test_s3_disk():
thread1.join() thread1.join()
assert ( assert (
node.query(f"select dequeued_requests>0 from system.scheduler where resource='network_read' and path='/prio/admin'") node.query(
f"select dequeued_requests>0 from system.scheduler where resource='network_read' and path='/prio/admin'"
)
== "1\n" == "1\n"
) )
assert ( assert (
node.query(f"select dequeued_requests>0 from system.scheduler where resource='network_read' and path='/prio/fair/dev'") node.query(
f"select dequeued_requests>0 from system.scheduler where resource='network_read' and path='/prio/fair/dev'"
)
== "1\n" == "1\n"
) )
assert ( assert (
node.query(f"select dequeued_requests>0 from system.scheduler where resource='network_read' and path='/prio/fair/prod'") node.query(
f"select dequeued_requests>0 from system.scheduler where resource='network_read' and path='/prio/fair/prod'"
)
== "1\n" == "1\n"
) )