1 # Copyright (C) 2007-2014 CEA/DEN, EDF R&D, OPEN CASCADE
3 # Copyright (C) 2003-2007 OPEN CASCADE, EADS/CCR, LIP6, CEA/DEN,
4 # CEDRAT, EDF R&D, LEG, PRINCIPIA R&D, BUREAU VERITAS
6 # This library is free software; you can redistribute it and/or
7 # modify it under the terms of the GNU Lesser General Public
8 # License as published by the Free Software Foundation; either
9 # version 2.1 of the License.
11 # This library is distributed in the hope that it will be useful,
12 # but WITHOUT ANY WARRANTY; without even the implied warranty of
13 # MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU
14 # Lesser General Public License for more details.
16 # You should have received a copy of the GNU Lesser General Public
17 # License along with this library; if not, write to the Free Software
18 # Foundation, Inc., 59 Temple Place, Suite 330, Boston, MA 02111-1307 USA
20 # See http://www.salome-platform.org/ or email : webmaster.salome@opencascade.com
28 # Import libbatch library
29 from libbatch import *
32 print "*******************************************************************************************"
33 print "This script tests the local batch submission based on SH. No specific configuration is"
34 print "needed for this test."
35 print "*******************************************************************************************"
37 # eventually remove any previous result
38 if (os.path.exists("resultdir/seconddirname/result.txt")):
39 os.remove("resultdir/seconddirname/result.txt")
43 # ... and its parameters ...
45 p[EXECUTABLE] = config.TEST_SOURCE_DIR + "/test_script.py";
46 p[ARGUMENTS] = ["copied_seta.py", "copied_setb.py", "orig_result.txt"];
47 p[NAME] = 'Test_Python_Local_SH'
48 p[WORKDIR] = config.TEST_LOCAL_SH_WORKDIR
49 p[INFILE] = [(config.TEST_SOURCE_DIR + '/seta.py', 'copied_seta.py'),
50 (config.TEST_SOURCE_DIR + '/setb.py', 'copied_setb.py')]
51 p[OUTFILE] = [('result.txt', 'orig_result.txt')]
53 # ... and its environment
55 e["MYENVVAR"] = "MYVALUE";
56 job.setEnvironnement(e)
60 c = BatchManagerCatalog.getInstance()
62 # Create a BatchManager of type Local_SH on localhost
63 bm = c('LOCAL')('localhost', '', SH)
65 # Submit the job to the BatchManager
66 jobid = bm.submitJob(job)
72 # Wait for the end of the job
73 state = bm.waitForJobEnd(jobid, config.TEST_LOCAL_SH_TIMEOUT);
77 print "Job", jobid, "is done"
78 bm.importOutputFiles(job, "resultdir/seconddirname")
80 print "Job", jobid, " finished in error"
81 bm.importOutputFiles(job, "resultdir/seconddirname")
84 print "Timeout while executing job"
87 if state != FINISHED and state != FAILED:
88 print "Error: Job not finished after timeout"
91 # test the result file
93 execfile('resultdir/seconddirname/result.txt', res)
94 if (res["c"] == 12 and res["MYENVVAR"] == "MYVALUE"):
95 print "OK, Expected result found."
98 print "result found : %s, expected : %s" % (res, 'res["c"] == 12 and res["MYENVVAR"] == "MYVALUE"')
101 if __name__ == "__main__":