Skip to main content

dispatch_custom_observation_aggregation

dag_ml::runtime

Function dispatch_custom_observation_aggregation 

Source 
pub fn dispatch_custom_observation_aggregation(
    plan: &ExecutionPlan,
    controllers: &RuntimeControllerRegistry,
    task_id: impl Into<String>,
    block: ObservationPredictionBlock,
    relations: SampleRelationSet,
    policy: AggregationPolicy,
    requested_sample_order: Vec<SampleId>,
) -> Result<PredictionBlock, DagMlError>