Skip to content

Commit

Permalink
Avoid additional optimization step
Browse files Browse the repository at this point in the history
  • Loading branch information
hendrikmakait committed Aug 15, 2024
1 parent 85b3041 commit 232843e
Showing 1 changed file with 1 addition and 2 deletions.
3 changes: 1 addition & 2 deletions tests/tpch/test_optimization.py
Original file line number Diff line number Diff line change
Expand Up @@ -44,7 +44,6 @@ def test_optimization(query, dataset_path, fs, client, scale):

def test_delay_computation_start(query, dataset_path, fs, client, scale):
func = getattr(dask_queries, f"query_{query:02d}")
result = func(dataset_path, fs, scale).optimize()
# Client.compute unblocks as soon as update_graph finishes, i.e. graph is
# submitted and parsed. This is the time until the dashboard kicks off
client.compute(result)
client.compute(func(dataset_path, fs, scale))

0 comments on commit 232843e

Please sign in to comment.