Method FinalizeStale

coderd/x/chatd/chatdebug/service.go:578–597

FinalizeStale finalizes stale in-flight debug rows and emits a broadcast.

(
	ctx context.Context,
)

// FinalizeStale finalizes stale in-flight debug rows and emits a broadcast.
func (s *Service) FinalizeStale(
	ctx context.Context,
) (database.FinalizeStaleChatDebugRowsRow, error) {
	now := s.clock.Now()
	result, err := s.db.FinalizeStaleChatDebugRows(
		chatdContext(ctx),
		database.FinalizeStaleChatDebugRowsParams{
			Now:           now,
			UpdatedBefore: now.Add(-s.staleThreshold()),
		},
	)
	if err != nil {
		return database.FinalizeStaleChatDebugRowsRow{}, err
	}

	if result.RunsFinalized > 0 || result.StepsFinalized > 0 {
		s.publishEvent(ctx, uuid.Nil, EventKindFinalize, uuid.Nil, uuid.Nil)
	}
	return result, nil
}

// FinalizeRunParams bundles the arguments for FinalizeRun.
type FinalizeRunParams struct {