Method ExpireTaskBlocks

internal/task/manager_test.go:868–905

(
	_ context.Context,
	mutation ExpireTaskBlocksMutation,
)

}

func (s *inMemoryManagerStore) ExpireTaskBlocks(
	_ context.Context,
	mutation ExpireTaskBlocksMutation,
) (ExpireTaskBlocksResult, error) {
	now := mutation.Now.UTC()
	if now.IsZero() {
		now = time.Date(2026, 4, 14, 15, 0, 0, 0, time.UTC)
	}
	expired := make([]TaskBlock, 0)
	taskIDs := make([]string, 0, len(s.blocks))
	for taskID := range s.blocks {
		taskIDs = append(taskIDs, taskID)
	}
	sort.Strings(taskIDs)
	for _, taskID := range taskIDs {
		taskBlocks := s.blocks[taskID]
		blockIDs := make([]string, 0, len(taskBlocks))
		for blockID := range taskBlocks {
			blockIDs = append(blockIDs, blockID)
		}
		sort.Strings(blockIDs)
		for _, blockID := range blockIDs {
			block := taskBlocks[blockID]
			if !block.ClearedAt.IsZero() || block.ExpiresAt.IsZero() || block.ExpiresAt.After(now) {
				continue
			}
			block.ClearedAt = now
			block.ClearedBy = ActorIdentity{
				Kind: mutation.ClearedBy.Kind.Normalize(),
				Ref:  strings.TrimSpace(mutation.ClearedBy.Ref),
			}
			block.ClearNote = ""
			taskBlocks[blockID] = cloneTaskBlock(block)
			expired = append(expired, cloneTaskBlock(block))
		}
	}
	return ExpireTaskBlocksResult{Blocks: expired}, nil
}

func (s *inMemoryManagerStore) BlockTaskAndReleaseRun(
	_ context.Context,