Skip to content

Send batch outcomes to aggregator #5495

@Dav1dde

Description

@Dav1dde

Instead of sending outcomes directly to the outcome_producer, they should be sent to the outcome_aggregator for another layer of aggregation.

Code:

let producer = &state.outcome_producer();
for outcome in body.inner.outcomes {
producer.send(outcome);
}

This means the aggregator needs to understand TrackRawOutcome or we want to potentially change the API (purely an internal API, so that's feasible).

Metadata

Metadata

Assignees

No one assigned

    Labels

    fillerRequires little effort to resolve. Ready to be picked up anytime.maintenanceTasks with this label generally have a lower priority and due datestarter

    Projects

    No projects

    Milestone

    No milestone

    Relationships

    None yet

    Development

    No branches or pull requests

    Issue actions