Method Retry

internal/daemon/memory_runtime.go:279–329

(
	ctx context.Context,
	req contract.MemoryExtractorRetryRequest,
)

}

func (e *daemonMemoryExtractor) Retry(
	ctx context.Context,
	req contract.MemoryExtractorRetryRequest,
) (contract.MemoryExtractorRetryResponse, error) {
	if e == nil || e.proposalSink == nil {
		return contract.MemoryExtractorRetryResponse{}, errors.New("daemon: memory extractor is not configured")
	}
	failures, err := e.loadFailures()
	if err != nil {
		return contract.MemoryExtractorRetryResponse{}, err
	}
	targetFailureID := strings.TrimSpace(req.FailureID)
	targetSessionID := strings.TrimSpace(req.SessionID)
	var response contract.MemoryExtractorRetryResponse
	for _, failure := range failures {
		if targetFailureID != "" && failure.Payload.ID != targetFailureID {
			continue
		}
		if targetSessionID != "" && failure.Payload.SessionID != targetSessionID {
			continue
		}
		if err := ctx.Err(); err != nil {
			return response, fmt.Errorf("daemon: retry memory extractor failures: %w", err)
		}
		candidates, decodeErr := failure.Candidates()
		if decodeErr != nil {
			response.Failed++
			continue
		}
		if len(candidates) == 0 {
			response.Failed++
			continue
		}
		var failed bool
		for _, candidate := range candidates {
			if _, proposeErr := e.proposalSink.ProposeCandidate(ctx, candidate); proposeErr != nil {
				failed = true
				break
			}
		}
		if failed {
			response.Failed++
			continue
		}
		if err := fileutil.AtomicRemoveFile(failure.Payload.Path); err != nil {
			return response, fmt.Errorf("daemon: remove retried extractor failure: %w", err)
		}
		response.Retried++
	}
	return response, nil
}

func (e *daemonMemoryExtractor) Drain(ctx context.Context) (contract.MemoryExtractorDrainResponse, error) {
	if e == nil || e.runtime == nil {