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

dags/layers/inspiral.py: track databases for file transfer in compute far layer

parent ea78d034
No related branches found
No related tags found
No related merge requests found
......@@ -595,17 +595,22 @@ def compute_far_layer(config, dag, trigger_cache, pdf_cache):
inj_triggers = inj_trigger_cache.groupby("time")
for span, noninj_triggers in noninj_trigger_cache.groupby("time").items():
databases = noninj_triggers.files
inputs = [
Option("non-injection-db", noninj_triggers.files),
Option("background-bins-file", pdf_cache.files),
]
if inj_triggers:
inputs.append(Option("injection-db", inj_triggers[span].files))
databases.extend(inj_triggers[span].files)
layer += Node(
arguments = Option("tmp-space", dagutil.condor_scratch_space()),
inputs = inputs,
outputs = Option("output-background-bins-file", post_pdf_cache.files),
outputs = [
Option("output-background-bins-file", post_pdf_cache.files),
Argument("databases", databases, suppress=True),
]
)
dag.attach(layer)
......
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