6
|
1 #!/usr/bin/env python
|
|
2
|
|
3 import os
|
|
4 import sys
|
|
5 import time
|
|
6 import shutil
|
|
7 from commons.core.checker.RepetException import RepetException
|
|
8 try:
|
|
9 newDir = None
|
|
10 print os.uname()
|
|
11 beginTime = time.time()
|
|
12 print 'beginTime=%f' % beginTime
|
|
13 print "work in dir '/home/user/workspace/repet_pipe/commons/core/launcher/test/dummyScratch'"
|
|
14 sys.stdout.flush()
|
|
15 if not os.path.exists( "/home/user/workspace/repet_pipe/commons/core/launcher/test/dummyScratch" ):
|
|
16 raise IOError("ERROR: temporary directory '/home/user/workspace/repet_pipe/commons/core/launcher/test/dummyScratch' doesn't exist")
|
|
17
|
|
18 minFreeGigaInTmpDir = 1
|
|
19 freeSpace = os.statvfs("/home/user/workspace/repet_pipe/commons/core/launcher/test/dummyScratch")
|
|
20 if ((freeSpace.f_bavail * freeSpace.f_frsize) / 1073741824.0 < minFreeGigaInTmpDir):
|
|
21 raise RepetException("ERROR: less than %iG of input file in '/home/user/workspace/repet_pipe/commons/core/launcher/test/dummyScratch'" % minFreeGigaInTmpDir)
|
|
22
|
|
23 os.chdir("/home/user/workspace/repet_pipe/commons/core/launcher/test/dummyScratch")
|
|
24 newDir = "groupid_job1_20110505-105353"
|
|
25 if os.path.exists(newDir):
|
|
26 shutil.rmtree(newDir)
|
|
27 os.mkdir(newDir)
|
|
28 os.chdir(newDir)
|
|
29
|
|
30 log = os.system("touch dummyFile1")
|
|
31 if log != 0:
|
|
32 raise RepetException("ERROR: job returned %i" % log)
|
|
33 else:
|
|
34 print "job finished successfully"
|
|
35 sys.stdout.flush()
|
|
36 shutil.move("dummyFile1", "/home/user/workspace/repet_pipe/commons/core/launcher/test")
|
|
37
|
|
38 os.chdir("..")
|
|
39 shutil.rmtree(newDir)
|
|
40 endTime = time.time()
|
|
41 print 'endTime=%f' % endTime
|
|
42 print 'executionTime=%f' % (endTime - beginTime)
|
|
43 print os.uname()
|
|
44 sys.stdout.flush()
|
|
45
|
|
46 except IOError, e :
|
|
47 print e
|
|
48 sys.stdout.flush()
|
|
49 sys.exit(1) |