Commit f1289576 authored by James Clark's avatar James Clark
Browse files

Merge branch 'master' of git.ligo.org:james-clark/gwrucio

parents 4ece7675 9a83f80a
Pipeline #83200 passed with stages
in 59 seconds
......@@ -52,7 +52,7 @@ class FileInfoJob(pipeline.CondorDAGJob):
## Arguments
self.add_condor_cmd('accounting_group', accounting_group)
self.add_condor_cmd('should_transfer_files', 'yes')
self.add_condor_cmd('should_transfer_files', 'YES')
## Write the submission file
self.set_sub_file('fileinfos.sub')
......@@ -114,7 +114,7 @@ if __name__ == "__main__":
ARGS = PARSER.parse_args(sys.argv[1:])
with open(ARGS.framelist, 'r') as FRAMESF:
FRAMES = FRAMESF.readlines()
FRAMES = FRAMESF.read().splitlines()
# Work in a directory named after the original reg file
WORKDIR = ARGS.framelist.replace('.txt', '')
......@@ -130,15 +130,20 @@ if __name__ == "__main__":
sys.exit(FAILURE)
print("Writing workflow in {}".format(WORKDIR))
# Executable
make_fileinfo()
## Define DAG and job types
DAG = pipeline.CondorDAG(log='fileinfos_pipe.log')
DAG.set_dag_file('fileinfos_pipe')
FILEINFO_JOB = FileInfoJob()
## Define DAG node
FILEINFO_NODE = FileInfoNode(FILEINFO_JOB)
FILEINFO_NODE.set_framefile('/i/am/a/frame')
DAG.add_node(FILEINFO_NODE)
for FRAME in FRAMES:
print(FRAME)
FILEINFO_NODE = FileInfoNode(FILEINFO_JOB)
FILEINFO_NODE.set_framefile(FRAME)
DAG.add_node(FILEINFO_NODE)
## Write the resulting DAG
DAG.write_sub_files()
......
Markdown is supported
0% or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment