@@ -78,14 +78,13 @@ def test_select_query_no_result(presto_connection):
7878
7979def test_select_query_stats (presto_connection ):
8080 cur = presto_connection .cursor ()
81- cur .execute ("SELECT * FROM tpch.sf1.customer" )
81+ cur .execute ("SELECT * FROM tpch.sf1.customer LIMIT 1000 " )
8282
8383 query_id = cur .stats ["queryId" ]
8484 completed_splits = cur .stats ["completedSplits" ]
8585 cpu_time_millis = cur .stats ["cpuTimeMillis" ]
8686 processed_bytes = cur .stats ["processedBytes" ]
8787 processed_rows = cur .stats ["processedRows" ]
88- user_time_millis = cur .stats ["userTimeMillis" ]
8988 wall_time_millis = cur .stats ["wallTimeMillis" ]
9089
9190 while cur .fetchone () is not None :
@@ -94,15 +93,13 @@ def test_select_query_stats(presto_connection):
9493 assert cpu_time_millis <= cur .stats ["cpuTimeMillis" ]
9594 assert processed_bytes <= cur .stats ["processedBytes" ]
9695 assert processed_rows <= cur .stats ["processedRows" ]
97- assert user_time_millis <= cur .stats ["userTimeMillis" ]
9896 assert wall_time_millis <= cur .stats ["wallTimeMillis" ]
9997
10098 query_id = cur .stats ["queryId" ]
10199 completed_splits = cur .stats ["completedSplits" ]
102100 cpu_time_millis = cur .stats ["cpuTimeMillis" ]
103101 processed_bytes = cur .stats ["processedBytes" ]
104102 processed_rows = cur .stats ["processedRows" ]
105- user_time_millis = cur .stats ["userTimeMillis" ]
106103 wall_time_millis = cur .stats ["wallTimeMillis" ]
107104
108105
0 commit comments