00001 #!/usr/bin/env ganga 00002 00003 import time 00004 import sys 00005 import os 00006 00007 #load BOSS Ganga libraries 00008 from GangaBoss.Lib.BossDataSet.BossDataSet import BossDataSet 00009 from GangaBoss.Lib.Boss import InterpretJob 00010 from GangaBoss import * 00011 00012 from Ganga.Core.exceptions import * 00013 00014 ##********************************************************************************** 00015 j=Job() 00016 j.name='BossRec' 00017 j.application = Boss(JobOptions= os.environ['HOME']+'/boss/Generator/Ekhara/Ekhara-00-00-09/run/gen_rec.txt') 00018 00019 ##********************************************************************************** 00020 #choose maximum number of events 00021 ##********************************************************************************** 00022 j.application.EvtMax=-1 00023 00024 ##********************************************************************************** 00025 ##Specify type of job: 'Rec/Ana' or 'Sim' 00026 ##********************************************************************************** 00027 j.application.JobType='Rec/Ana' 00028 00029 ##********************************************************************************** 00030 ##specify input data 00031 ##********************************************************************************** 00032 ##read input data from BOSS option file 00033 #j.Input_files=InterpretJob(j.application.JobOptions).read_input() 00034 00035 ##********************************************************************************** 00036 ##choose splitter 00037 ##jobs are crashing with more than 4 files per job 00038 ##********************************************************************************** 00039 #j.splitter = None 00040 #j.splitter = SmartSplitter ( NodeNumber = 8 , FileSizePerJob = 2000000000L, maxFiles=-1) 00041 j.splitter = FileSplitter (filesPerJob = 2, maxFiles=-1) 00042 00043 ##********************************************************************************** 00044 ##choose merger: SmartMerger, MultipleMerger, RootMerger, TextMerger, CustomMerger 00045 ##********************************************************************************** 00046 merger = CustomMerger() 00047 merger.files = ['test.dst'] 00048 merger.ignorefailed = True 00049 merger.overwrite = True 00050 merger.module = '/data/work/kpha1/prencipe/local/raid0/bes3/Ganga/gencardMerger.py' 00051 j.merger = merger 00052 00053 ##********************************************************************************** 00054 ##choose backend 00055 ##********************************************************************************** 00056 #j.backend = Local() 00057 ##choose queue: 'batch' or 'batch_x86_64' 00058 #j.backend = PBS(queue='batch_x86_64') 00059 j.backend = PBS() 00060 00061 ##********************************************************************************** 00062 ##select files stored in output directory 00063 ##********************************************************************************** 00064 j.outputsandbox = ['*.root','*.txt','*.dst'] 00065 00066 ##********************************************************************************** 00067 ##finally sumbit job 00068 ##********************************************************************************** 00069 #j.submit()
1.4.7