func()

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
}