in accumulator/batch.go [328:343]
func (b *Batch) finalizeInvocation(reqID, status string, endTime time.Time) error {
inc, ok := b.invocations[reqID]
if !ok {
return fmt.Errorf("invocation for requestID %s does not exist", reqID)
}
proxyTxn, err := inc.MaybeCreateProxyTxn(status, endTime)
if err != nil {
return err
}
err = b.addData(proxyTxn)
if err != nil {
return err
}
inc.Finalized = true
return nil
}