57namespace analysis_task_parsers
67template <is_configurable O>
68bool appendOption(std::vector<ConfigParamSpec>& options, O& option)
73template <is_configurable_group O>
74bool appendOption(std::vector<ConfigParamSpec>& options, O& optionGroup)
76 if constexpr (
requires { optionGroup.prefix; }) {
77 homogeneous_apply_refs<true>([prefix = optionGroup.prefix]<
typename C>(C& option) {
78 if constexpr (requires { option.name; }) {
79 option.name.insert(0, 1,
'.');
80 option.name.insert(0, prefix);
86 homogeneous_apply_refs<true>([&options](
auto& option) {
return appendOption(options, option); }, optionGroup);
96template <is_configurable O>
97bool prepareOption(
InitContext& context, O& configurable)
100 configurable.value = context.
options().
get<
typename O::type>(configurable.name.c_str());
102 auto pt = context.
options().
get<boost::property_tree::ptree>(configurable.name.c_str());
103 configurable.value = RootConfigParamHelpers::as<typename O::type>(pt);
108template <is_configurable_group O>
109bool prepareOption(InitContext& context, O& configurableGroup)
111 homogeneous_apply_refs<true>([&context](
auto&& configurable) {
return prepareOption(context, configurable); }, configurableGroup);
122template <is_condition C>
123bool appendCondition(std::vector<InputSpec>& inputs, C& condition)
129template <is_condition_group C>
130bool appendCondition(std::vector<InputSpec>& inputs, C& conditionGroup)
132 homogeneous_apply_refs<true>([&inputs](
auto& condition) {
return appendCondition(inputs, condition); }, conditionGroup);
143template <is_spawns T>
146 return "control:spawn";
149template <is_builds T>
150const char* controlOption()
152 return "control:build";
155template <is_defines T>
156const char* controlOption()
158 return "control:define";
162 requires(is_spawns<T> || is_builds<T> || is_defines<T>)
165 auto base_specs = entity.base_specs();
166 for (
auto base_spec : base_specs) {
179template <is_condition C>
180bool newDataframeCondition(
InputRecord& record, C& condition)
182 condition.instance = (
typename C::type*)record.
get<
typename C::type*>(condition.path).get();
186template <is_condition_group C>
187bool newDataframeCondition(
InputRecord& record, C& conditionGroup)
189 homogeneous_apply_refs<true>([&record](
auto&& condition) {
return newDataframeCondition(record, condition); }, conditionGroup);
200template <is_produces T>
201bool appendOutput(std::vector<OutputSpec>& outputs, T&, uint32_t)
207template <is_produces_group T>
208bool appendOutput(std::vector<OutputSpec>& outputs, T& producesGroup, uint32_t hash)
210 homogeneous_apply_refs<true>([&outputs, hash](
auto& produces) {
return appendOutput(outputs, produces, hash); }, producesGroup);
214template <is_histogram_registry T>
215bool appendOutput(std::vector<OutputSpec>& outputs, T& hr, uint32_t hash)
218 outputs.emplace_back(hr.spec());
222template <is_outputobj T>
223bool appendOutput(std::vector<OutputSpec>& outputs, T& obj, uint32_t hash)
226 outputs.emplace_back(obj.spec());
231 requires(is_spawns<T> || is_builds<T> || is_defines<T>)
232bool appendOutput(std::vector<OutputSpec>& outputs, T& entity, uint32_t)
234 outputs.emplace_back(entity.spec());
244template <is_histogram_registry T>
248 context.
outputs().
snapshot(hr.ref(deviceSpec.inputTimesliceId, deviceSpec.maxInputTimeslices), *(hr.getListOfHistograms()));
253template <is_outputobj T>
257 context.
outputs().
snapshot(obj.ref(deviceSpec.inputTimesliceId, deviceSpec.maxInputTimeslices), *obj);
267template <is_produces T>
274template <is_produces_group T>
277 homogeneous_apply_refs<true>([&context](
auto& produces) {
return prepareOutput(context, produces); }, producesGroup);
281template <is_spawns T>
285 auto originalTable =
soa::ArrowHelpers::joinTables(extractOriginals<metadata::sources.
size(), metadata::sources>(context), std::span{metadata::base_table_t::originalLabels});
286 if (originalTable->schema()->fields().empty() ==
true) {
287 using base_table_t =
typename T::base_table_t::table_t;
288 originalTable = makeEmptyTable<base_table_t>(o2::aod::label<metadata::extension_table_t::ref>());
290 using D =
o2::aod::Hash<metadata::extension_table_t::ref.desc_hash>;
292 spawns.extension = std::make_shared<typename T::extension_t>(o2::framework::spawner<D>(originalTable,
293 o2::aod::label<metadata::extension_table_t::ref>(),
294 spawns.projectors.data(),
297 spawns.table = std::make_shared<typename T::spawnable_t::table_t>(
soa::ArrowHelpers::joinTables({spawns.extension->asArrowTable(), originalTable}, std::span{T::spawnable_t::table_t::originalLabels}));
301template <is_builds T>
305 return builds.template build<typename T::buildable_t::indexing_t>(builds.pack(), extractOriginals<metadata::sources.size(), metadata::sources>(context));
308template <is_defines T>
310 requires(T::delayed ==
false)
313 auto originalTable =
soa::ArrowHelpers::joinTables(extractOriginals<metadata::sources.
size(), metadata::sources>(context), std::span{metadata::base_table_t::originalLabels});
314 if (originalTable->schema()->fields().empty() ==
true) {
315 using base_table_t =
typename T::base_table_t::table_t;
316 originalTable = makeEmptyTable<base_table_t>(o2::aod::label<metadata::extension_table_t::ref>());
318 if (defines.inputSchema ==
nullptr) {
319 defines.inputSchema = originalTable->schema();
321 using D =
o2::aod::Hash<metadata::extension_table_t::ref.desc_hash>;
323 defines.extension = std::make_shared<typename T::extension_t>(o2::framework::spawner<D>(originalTable,
324 o2::aod::label<metadata::extension_table_t::ref>(),
325 defines.projectors.data(),
328 defines.table = std::make_shared<typename T::spawnable_t::table_t>(
soa::ArrowHelpers::joinTables({defines.extension->asArrowTable(), originalTable}, std::span{T::spawnable_t::table_t::originalLabels}));
338template <is_defines T>
339 requires(T::delayed ==
true)
342 if (defines.needRecompilation) {
346 auto originalTable =
soa::ArrowHelpers::joinTables(extractOriginals<metadata::sources.
size(), metadata::sources>(context), std::span{metadata::base_table_t::originalLabels});
347 if (originalTable->schema()->fields().empty() ==
true) {
348 using base_table_t =
typename T::base_table_t::table_t;
349 originalTable = makeEmptyTable<base_table_t>(o2::aod::label<metadata::extension_table_t::ref>());
351 if (defines.inputSchema ==
nullptr) {
352 defines.inputSchema = originalTable->schema();
354 using D =
o2::aod::Hash<metadata::extension_table_t::ref.desc_hash>;
356 defines.extension = std::make_shared<typename T::extension_t>(o2::framework::spawner<D>(originalTable,
357 o2::aod::label<metadata::extension_table_t::ref>(),
358 defines.projectors.data(),
361 defines.table = std::make_shared<typename T::spawnable_t::table_t>(
soa::ArrowHelpers::joinTables({defines.extension->asArrowTable(), originalTable}, std::span{T::spawnable_t::table_t::originalLabels}));
371template <is_produces T>
374 produces.setLabel(o2::aod::label<T::persistent_table_t::ref>());
379template <is_produces_group T>
382 homogeneous_apply_refs<true>([&context](
auto& produces) {
return finalizeOutput(context, produces); }, producesGroup);
386template <is_spawns T>
389 context.outputs().adopt(spawns.output(), spawns.asArrowTable());
393template <is_builds T>
396 context.outputs().adopt(builds.output(), builds.asArrowTable());
400template <is_defines T>
403 context.outputs().adopt(defines.output(), defines.asArrowTable());
414template <is_service T>
415bool addService(std::vector<ServiceSpec>& specs, T&)
418 auto p =
typename T::service_t{};
420 PluginManager::loadFromPlugin<ServiceSpec, ServicePlugin>(loadableServices, specs);
431template <is_service T>
432bool prepareService(
InitContext& context, T& service)
434 using S =
typename T::service_t;
435 if constexpr (
requires { &S::instance; }) {
436 service.service = &(S::instance());
451template <is_service T>
456 if constexpr (
requires { &T::service_t::endOfStream; }) {
457 service.service->endOfStream();
470template <expressions::is_filter T>
477template <is_partition T>
478bool updatePlaceholders(
InitContext& context, T& partition)
480 partition.updatePlaceholders(context);
490template <expressions::is_filter T>
491bool createExpressionTrees(std::vector<ExpressionInfo>& expressionInfos, T&
filter)
503template <is_partition T>
504bool newDataframePartition(T& partition)
506 partition.dataframeChanged =
true;
510template <
typename P,
typename... T>
518 ([&]() {
if constexpr (std::same_as<typename P::content_t, T>) {partition.bindTable(tables);} }(), ...);
521template <
typename P,
typename T>
526template <is_partition P,
typename T>
527void bindInternalIndicesPartition(
P& partition, T* table)
529 if constexpr (o2::soa::is_binding_compatible_v<typename P::content_t, std::decay_t<T>>()) {
530 partition.bindInternalIndicesTo(table);
534template <
typename P,
typename... T>
542 partition.bindExternalIndices(tables...);
558template <is_slice_cache T>
561 if (cache.ptr ==
nullptr) {
568template <
typename C,
typename TG,
typename... Ts>
574static void setGroupedCombination(C& comb, TG& grouping, std::tuple<Ts...>& associated)
576 if constexpr (std::same_as<typename C::g_t, std::decay_t<TG>>) {
577 comb.setTables(grouping, associated);
583 requires(!is_preslice<T>)
589template <is_preslice T>
590 requires std::same_as<typename T::policy_t, framework::PreslicePolicySorted>
593 if constexpr (T::optional) {
594 if (preslice.binding ==
"[MISSING]") {
598 auto locate = std::find_if(bsks.begin(), bsks.end(), [&](
auto const&
entry) { return (entry.binding == preslice.bindingKey.binding) && (entry.key == preslice.bindingKey.key); });
599 if (locate == bsks.end()) {
600 bsks.emplace_back(preslice.getBindingKey());
601 }
else if (locate->enabled ==
false) {
602 locate->enabled =
true;
607template <is_preslice T>
608 requires std::same_as<typename T::policy_t, framework::PreslicePolicyGeneral>
611 if constexpr (T::optional) {
612 if (preslice.binding ==
"[MISSING]") {
616 auto locate = std::find_if(bsksU.begin(), bsksU.end(), [&](
auto const&
entry) { return (entry.binding == preslice.bindingKey.binding) && (entry.key == preslice.bindingKey.key); });
617 if (locate == bsksU.end()) {
618 bsksU.emplace_back(preslice.getBindingKey());
619 }
else if (locate->enabled ==
false) {
620 locate->enabled =
true;
632template <is_preslice T>
634 requires std::same_as<typename T::policy_t, framework::PreslicePolicySorted>
636 if constexpr (T::optional) {
637 if (preslice.binding ==
"[MISSING]") {
641 preslice.updateSliceInfo(cache.getCacheFor(preslice.getBindingKey()));
645template <is_preslice T>
647 requires std::same_as<typename T::policy_t, framework::PreslicePolicyGeneral>
649 if constexpr (T::optional) {
650 if (preslice.binding ==
"[MISSING]") {
654 preslice.updateSliceInfo(cache.getCacheUnsortedFor(preslice.getBindingKey()));
660static bool setProcessSwitch(std::pair<std::string, bool>, T&)
665template <is_process_configurable T>
666static bool setProcessSwitch(std::pair<std::string, bool> setting, T& pc)
668 if (pc.name == setting.first) {
669 pc.value = setting.second;