dingo.pipe.nodes package

Submodules

dingo.pipe.nodes.generation_node module

class dingo.pipe.nodes.generation_node.GenerationNode(inputs, trigger_time, idx, dag, parent=None, importance_sampling=False)

Bases: GenerationNode

Node for data generation jobs with DINGO-specific customizations

property event_data_file

property executable

property job_name

setup_arguments(**kwargs)

dingo.pipe.nodes.importance_sampling_node module

class dingo.pipe.nodes.importance_sampling_node.ImportanceSamplingNode(inputs, sampling_node, generation_node, parallel_idx, dag)

Bases: AnalysisNode

property executable

property request_memory

property result_file

dingo.pipe.nodes.merge_node module

class dingo.pipe.nodes.merge_node.MergeNode(**kwargs)

Bases: MergeNode

property executable

property result_file

run_node_on_osg = False

dingo.pipe.nodes.pe_summary_node module

class dingo.pipe.nodes.pe_summary_node.PESummaryNode(inputs, merged_node_list, generation_node_list, dag)

Bases: PESummaryNode

run_node_on_osg = False

dingo.pipe.nodes.plot_node module

class dingo.pipe.nodes.plot_node.PlotNode(inputs, merged_node, dag)

Bases: PlotNode

property executable

run_node_on_osg = False

class dingo.pipe.nodes.plot_node.PlotPPNode(inputs, merged_node_list, dag)