Skip to content
Snippets Groups Projects
Commit fb5e409e authored by Patrick Godwin's avatar Patrick Godwin
Browse files

gstlal_feature_extractor_pipe: fixed bug where jobs were created for time...

gstlal_feature_extractor_pipe: fixed bug where jobs were created for time stretches in which there was no analyzable time
parent 9c870769
No related branches found
No related tags found
No related merge requests found
......@@ -118,6 +118,12 @@ def feature_extractor_node_gen(gstlalFeatureExtractorJob, dag, parent_nodes, seg
# parallelize jobs by segments
for seg in segsdict[ifo]:
# only produce jobs where the analysis runtime after applying segments is nonzero
if not data_source_info.frame_segments[ifo].intersects_segment(seg):
if options.verbose:
print "Skipping %s since there is no analyzable data here" % repr(seg)
continue
# set maximum number of jobs reading concurrently from the same frame file to prevent I/O locks
if ii / options.concurrency == 0:
dep_nodes = parent_nodes
......
0% Loading or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment