Skip to content

Commit

Permalink
Fix test_parallel
Browse files Browse the repository at this point in the history
  • Loading branch information
auxten committed Jan 3, 2025
1 parent c7bd95a commit 9bbfd3a
Showing 1 changed file with 4 additions and 2 deletions.
6 changes: 4 additions & 2 deletions tests/test_parallel.py
Original file line number Diff line number Diff line change
Expand Up @@ -20,15 +20,17 @@


def run_query(query, fmt):
res = chdb.query(query, "JSON")
res = chdb.query(query, fmt)
# print(res)
if len(res) < 100:
print(f"Error: result size is not correct {len(res)}")
# exit(1)


def run_queries(query, fmt, count=query_count):
for _ in range(count):
for i in range(count):
if i % 5 == 0:
print(f"Running {i} queries")
run_query(query, fmt)


Expand Down

0 comments on commit 9bbfd3a

Please sign in to comment.