12from pathlib
import Path
14from caf
import backends
17from basf2
import B2INFO, logging, LogLevel, LogInfo
18currentInfo = logging.get_info(LogLevel.INFO)
19logging.set_info(LogLevel.INFO, currentInfo | LogInfo.TIMESTAMP)
22probcut = float(sys.argv[1])
if len(sys.argv) == 2
else 0.001
26with open(
'runlist')
as runlist:
27 lines = runlist.readlines()
29 input_files.append(line.rstrip(
'\n'))
42job1 = backends.Job(
"CDC_Colllector")
43job1.output_dir = str(Path(root_dir).absolute())
44job1.working_dir = str(Path(root_dir).absolute())
47job1.cmd = [
'basf2',
'run_collector.py', str(probcut)]
49job1.input_sandbox_files.append(
"run_collector.py")
58job1.input_files = input_files
63job1.max_files_per_subjob = 1
65job1.backend_args[
'queue'] =
's'
74 B2INFO(
"Are we done?")
76 B2INFO(
"Not done yet, will sleep")