Method ExpireTaskBlocks

internal/task/block_service.go:371–414

ExpireTaskBlocks finalizes expired transient blocks through service-owned transitions.

(
	ctx context.Context,
	now time.Time,
	actor ActorContext,
)

// ExpireTaskBlocks finalizes expired transient blocks through service-owned transitions.
func (m *Service) ExpireTaskBlocks(
	ctx context.Context,
	now time.Time,
	actor ActorContext,
) (ExpireTaskBlocksResult, error) {
	if err := requireWriteAuthority(actor); err != nil {
		return ExpireTaskBlocksResult{}, err
	}
	expireAt := now.UTC()
	if expireAt.IsZero() {
		expireAt = m.now().UTC()
	}
	result, err := m.store.ExpireTaskBlocks(ctx, ExpireTaskBlocksMutation{
		Now:       expireAt,
		ClearedBy: actor.Actor,
	})
	if err != nil {
		return ExpireTaskBlocksResult{}, err
	}
	blocksByTask := make(map[string][]TaskBlock)
	taskIDs := make([]string, 0)
	for _, block := range result.Blocks {
		if _, ok := blocksByTask[block.TaskID]; !ok {
			taskIDs = append(taskIDs, block.TaskID)
		}
		blocksByTask[block.TaskID] = append(blocksByTask[block.TaskID], block)
	}
	for _, taskID := range taskIDs {
		blocks := blocksByTask[taskID]
		reconciled, reconcileErr := m.reconcileTaskCascade(ctx, taskID)
		if reconcileErr != nil {
			return ExpireTaskBlocksResult{}, reconcileErr
		}
		for _, block := range blocks {
			m.recordTaskBlockExpired(ctx, block, reconciled, actor)
			m.dispatchTaskUnblocked(ctx, block, reconciled, actor)
		}
		m.autoEnqueueReadyTaskDetached(ctx, taskID, autoEnqueueTrigger{
			Kind: autoEnqueueTriggerTransientExpiry,
			Ref:  transientExpiryTriggerRef(blocks),
		}, actor)
	}
	return result, nil
}

func transientExpiryTriggerRef(blocks []TaskBlock) string {
	if len(blocks) == 1 {