o2::framework::workflow Namespace Reference

Functions
WorkflowSpec	combine (const char *name, std::vector< DataProcessorSpec > const &specs, bool doIt)
template<typename T , typename... ARGS>
WorkflowSpec	concat (T &&t, ARGS &&... args)

Function Documentation

combine()

WorkflowSpec o2::framework::workflow::combine	(	const char *	name,
		std::vector< DataProcessorSpec > const &	specs,
		bool	doIt
	)

This allows to optionally merge specs into a single DataProcessorSpec named name if the doIt variable is true. If doIt is false, the function will simply return the original specs.

This implements at a different level the functionality proposed by Sandro in https://github.com/AliceO2Group/AliceO2/pull/8529 which was working at the reconstruction task level. This is a bit more general and can be used for analysis tasks as well (T). In the long term it might make sense to automatically apply this after the topological sort and to automatically merge the parallel paths of the workflow. Merging serial steps is more complicated because it would require to abstract out the FairMQ channel model.

Definition at line 159 of file WorkflowSpec.cxx.

concat()

template<typename T , typename... ARGS>

WorkflowSpec o2::framework::workflow::concat	(	T &&	t,
		ARGS &&...	args
	)

Definition at line 129 of file WorkflowSpec.h.