Skip to content

Commit b76afb9

Browse files
committed
Copy additional files in advanced to avoid conflict when running 8 and 16 nodes tests in parallel
1 parent f24e073 commit b76afb9

File tree

2 files changed

+5
-3
lines changed

2 files changed

+5
-3
lines changed

tests/integration-tests/tests/performance_tests/test_openfoam.py

Lines changed: 2 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -39,7 +39,6 @@ def run_openfoam_test(remote_command_executor, test_datadir, number_of_nodes):
3939
logging.info(f"Submitting OpenFOAM job with {number_of_nodes} nodes")
4040
remote_command_executor.run_remote_command(
4141
f'bash openfoam.slurm.sh "{subspace_benchmarks_dir}" "{number_of_nodes}" 2>&1',
42-
additional_files=[str(test_datadir / "openfoam.slurm.sh")],
4342
timeout=OPENFOAM_JOB_TIMEOUT,
4443
)
4544
perf_test_result = remote_command_executor.run_remote_script(
@@ -78,6 +77,8 @@ def test_openfoam(
7877
logging.info("OpenFOAM Installed")
7978
performance_degradation = {}
8079

80+
# Copy additional files in advanced to avoid conflict when running 8 and 16 nodes tests in parallel
81+
remote_command_executor._copy_additional_files([str(test_datadir / "openfoam.slurm.sh")])
8182
# Run 8 and 16 node tests in parallel
8283
with ThreadPoolExecutor(max_workers=2) as executor:
8384
future_8 = executor.submit(run_openfoam_test, remote_command_executor, test_datadir, 8)

tests/integration-tests/tests/performance_tests/test_starccm.py

Lines changed: 3 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -51,8 +51,7 @@ def starccm_installed(headnode):
5151
def run_starccm_test(remote_command_executor, scheduler_commands, test_datadir, number_of_nodes, podkey, licpath):
5252
num_of_tasks = number_of_nodes * TASK_VCPUS
5353
result = remote_command_executor.run_remote_command(
54-
f'sbatch --ntasks={num_of_tasks} starccm.slurm.sh "{podkey}" "{licpath}"',
55-
additional_files=[str(test_datadir / "starccm.slurm.sh")],
54+
f'sbatch --ntasks={num_of_tasks} starccm.slurm.sh "{podkey}" "{licpath}"'
5655
)
5756
logging.info(f"Submitting StarCCM+ job with {number_of_nodes} nodes")
5857
job_id = scheduler_commands.assert_job_submitted(result.stdout)
@@ -108,6 +107,8 @@ def test_starccm(
108107
podkey, licpath = get_starccm_secrets(region)
109108
performance_degradation = {}
110109

110+
# Copy additional files in advanced to avoid conflict when running 8 and 16 nodes tests in parallel
111+
remote_command_executor._copy_additional_files([str(test_datadir / "starccm.slurm.sh")])
111112
# Run 8 and 16 node tests in parallel
112113
with ThreadPoolExecutor(max_workers=2) as executor:
113114
future_8 = executor.submit(

0 commit comments

Comments
 (0)