|
56 | 56 | wait_for_num_nodes_in_scheduler,
|
57 | 57 | )
|
58 | 58 | from tests.common.scaling_common import setup_ec2_launch_override_to_emulate_ice
|
59 |
| -from tests.common.schedulers_common import SlurmCommands, TorqueCommands |
| 59 | +from tests.common.schedulers_common import SlurmCommands |
60 | 60 |
|
61 | 61 |
|
62 | 62 | @pytest.mark.usefixtures("instance", "os")
|
@@ -120,8 +120,6 @@ def test_slurm(
|
120 | 120 | max_count=5,
|
121 | 121 | gpu_instance_type_info=gpu_instance_type_info,
|
122 | 122 | )
|
123 |
| - # Test torque command wrapper |
124 |
| - _test_torque_job_submit(remote_command_executor, test_datadir) |
125 | 123 |
|
126 | 124 | # Tests below must run on HeadNode or need HeadNode participate.
|
127 | 125 | head_node_command_executor = RemoteCommandExecutor(cluster)
|
@@ -241,8 +239,6 @@ def test_slurm_from_login_nodes_in_private_network(
|
241 | 239 | max_count=5,
|
242 | 240 | gpu_instance_type_info=gpu_instance_type_info,
|
243 | 241 | )
|
244 |
| - # Test torque command wrapper |
245 |
| - _test_torque_job_submit(remote_command_executor, test_datadir) |
246 | 242 | head_node_command_executor = RemoteCommandExecutor(cluster)
|
247 | 243 | assert_no_errors_in_logs(head_node_command_executor, "slurm")
|
248 | 244 |
|
@@ -1809,14 +1805,6 @@ def _assert_job_state(slurm_commands, job_id, job_state):
|
1809 | 1805 | assert_that(e.result.stdout).contains("slurm_load_jobs error: Invalid job id specified")
|
1810 | 1806 |
|
1811 | 1807 |
|
1812 |
| -def _test_torque_job_submit(remote_command_executor, test_datadir): |
1813 |
| - """Test torque job submit command in slurm cluster.""" |
1814 |
| - logging.info("Testing cluster submits job by torque command") |
1815 |
| - torque_commands = TorqueCommands(remote_command_executor) |
1816 |
| - result = torque_commands.submit_script(str(test_datadir / "torque_job.sh")) |
1817 |
| - torque_commands.assert_job_submitted(result.stdout) |
1818 |
| - |
1819 |
| - |
1820 | 1808 | def _submit_kill_networking_job(remote_command_executor, scheduler_commands, partition, node_type, num_nodes):
|
1821 | 1809 | """Submit job that will detach network interface on compute."""
|
1822 | 1810 | # Get network interface name from Head node, assuming Head node and Compute are of the same instance type
|
|
0 commit comments