00001
00002
00003 import os
00004 import sys
00005
00006 if(len(sys.argv)<2):
00007 print("example: sub_merge.py tag [queue] [nclus]")
00008 sys.exit()
00009 else:
00010 tagname = str(sys.argv[1])
00011
00012 if(len(sys.argv)>=3):
00013 queue = str(sys.argv[2])
00014 else:
00015 queue = "offline"
00016
00017 if(len(sys.argv)>=4):
00018 nclus = int(sys.argv[3])
00019 else:
00020 nclus = 10
00021
00022
00023 newjobnum = 1
00024 newf = open("job_merge_" + str(newjobnum) , "w")
00025 os.system("chmod u+x " + "job_merge_" + str(newjobnum))
00026 count = 1
00027 dirList=os.listdir("./")
00028 for fname in dirList:
00029 if(count == nclus+1):
00030 count = 0
00031 newjobnum += 1
00032 newf.close()
00033 if(count == 0):
00034 newf = open("job_merge_" + str(newjobnum), "w")
00035 os.system("chmod u+x " + "job_merge_" + str(newjobnum))
00036 count += 1
00037 if(fname.find(tagname)>-1):
00038 newf.write("boss.exe " + fname + "\n")
00039 count += 1
00040
00041
00042
00043
00044