From 21f1e55a823f1afc0d849ebdc69aed7c42aac60c Mon Sep 17 00:00:00 2001 From: Hendrik Makait Date: Fri, 9 Feb 2024 22:01:17 +0100 Subject: [PATCH] Adjust default cluster sizes --- tests/tpch/conftest.py | 14 +++++++------- 1 file changed, 7 insertions(+), 7 deletions(-) diff --git a/tests/tpch/conftest.py b/tests/tpch/conftest.py index 693be9fe19..78516c04ac 100644 --- a/tests/tpch/conftest.py +++ b/tests/tpch/conftest.py @@ -147,7 +147,7 @@ def cluster_spec(scale): if scale == 10: return { "worker_vm_types": ["m6i.large"], - "n_workers": 16, + "n_workers": 8, **everywhere, } elif scale == 100: @@ -158,15 +158,15 @@ def cluster_spec(scale): } elif scale == 1000: return { - "worker_vm_types": ["m6i.large"], + "worker_vm_types": ["m6i.xlarge"], "n_workers": 32, **everywhere, } elif scale == 10000: return { - "worker_vm_types": ["m6i.2xlarge"], - "n_workers": 64, - "worker_disk_size": 100, + "worker_vm_types": ["m6i.xlarge"], + "n_workers": 32, + "worker_disk_size": 200, **everywhere, } @@ -294,7 +294,7 @@ def fs(local): def machine_spec(scale): if scale == 10: return { - "vm_type": "m6i.8xlarge", + "vm_type": "m6i.4xlarge", } elif scale == 100: return { @@ -302,7 +302,7 @@ def machine_spec(scale): } elif scale == 1000: return { - "vm_type": "m6i.16xlarge", + "vm_type": "m6i.32xlarge", } elif scale == 10000: return {