@@ 76-88 (lines=13) @@ | ||
73 | assert_equal(job_generator.pbs_list[0].commands, self.commands[:2]) |
|
74 | assert_equal(job_generator.pbs_list[1].commands, self.commands[2:]) |
|
75 | ||
76 | def test_generate_pbs4_gpu(self): |
|
77 | # Should needs four PBS files |
|
78 | command_params = {'nb_gpus_per_command': self.gpus} |
|
79 | job_generator = JobGenerator(self.queue_gpu, self.commands, command_params=command_params) |
|
80 | assert_equal(len(job_generator.pbs_list), 4) |
|
81 | assert_equal([pbs.commands[0] for pbs in job_generator.pbs_list], self.commands) |
|
82 | ||
83 | # Since queue has gpus it should be specified in PBS resource `nodes` |
|
84 | assert_true('gpus' in job_generator.pbs_list[0].resources['nodes']) |
|
85 | ||
86 | # Test modules to load |
|
87 | # Check if needed modules for this queue are included in the PBS file |
|
88 | assert_equal(job_generator.pbs_list[0].modules, self.modules) |
|
89 | ||
90 | def test_write_pbs_files(self): |
|
91 | commands = ["echo 1", "echo 2", "echo 3", "echo 4"] |
|
@@ 53-65 (lines=13) @@ | ||
50 | assert_equal(job_generator.pbs_list[0].commands, self.commands[:2]) |
|
51 | assert_equal(job_generator.pbs_list[1].commands, self.commands[2:]) |
|
52 | ||
53 | def test_generate_pbs4_cpu(self): |
|
54 | # Should needs four PBS file |
|
55 | command_params = {'nb_cores_per_command': self.cores} |
|
56 | job_generator = JobGenerator(self.queue, self.commands, command_params=command_params) |
|
57 | assert_equal(len(job_generator.pbs_list), 4) |
|
58 | assert_equal([pbs.commands[0] for pbs in job_generator.pbs_list], self.commands) |
|
59 | ||
60 | # Since queue has no gpus it should not be specified in PBS resource `nodes` |
|
61 | assert_true('gpus' not in job_generator.pbs_list[0].resources['nodes']) |
|
62 | ||
63 | # Test modules to load |
|
64 | # Check if needed modules for this queue are included in the PBS file |
|
65 | assert_equal(job_generator.pbs_list[0].modules, self.modules) |
|
66 | ||
67 | def test_generate_pbs2_gpu(self): |
|
68 | # Test nb_gpus_per_command argument |
|
@@ 35-43 (lines=9) @@ | ||
32 | def tearDown(self): |
|
33 | shutil.rmtree(self.testing_dir) |
|
34 | ||
35 | def test_generate_pbs(self): |
|
36 | job_generator = JobGenerator(self.queue, self.commands, prolog=self.prolog, epilog=self.epilog) |
|
37 | ||
38 | # Test nb_cores_per_command argument |
|
39 | # Should needs one PBS file |
|
40 | assert_equal(len(job_generator.pbs_list), 1) |
|
41 | assert_equal(job_generator.pbs_list[0].commands, self.commands) |
|
42 | assert_equal(job_generator.pbs_list[0].prolog, self.prolog) |
|
43 | assert_equal(job_generator.pbs_list[0].epilog, self.epilog) |
|
44 | ||
45 | def test_generate_pbs2_cpu(self): |
|
46 | # Should needs two PBS file |