Method autoEnqueueReadyTasks

internal/task/lease_manager.go:376–409

(
	ctx context.Context,
	taskIDs []string,
	trigger autoEnqueueTrigger,
	actor ActorContext,
)

}

func (m *Service) autoEnqueueReadyTasks(
	ctx context.Context,
	taskIDs []string,
	trigger autoEnqueueTrigger,
	actor ActorContext,
) {
	normalizedTrigger := trigger.normalized()
	if normalizedTrigger.Kind == "" || normalizedTrigger.Ref == "" {
		slog.Warn(
			"task: auto-enqueue skipped invalid trigger",
			"trigger_kind",
			trigger.Kind,
			"trigger_ref",
			trigger.Ref,
		)
		return
	}
	var pauseReader effectiveTaskPauseReader
	if reader, ok := m.store.(effectiveTaskPauseReader); ok {
		pauseReader = reader
	}
	seen := make(map[string]struct{}, len(taskIDs))
	for _, taskID := range taskIDs {
		trimmedTaskID := strings.TrimSpace(taskID)
		if trimmedTaskID == "" {
			continue
		}
		if _, ok := seen[trimmedTaskID]; ok {
			continue
		}
		seen[trimmedTaskID] = struct{}{}
		m.autoEnqueueReadyTask(ctx, trimmedTaskID, normalizedTrigger, pauseReader, actor)
	}
}

func (m *Service) autoEnqueueReadyTask(
	ctx context.Context,