Method activateRun

internal/daemon/task_role_runtime.go:172–219

(
	ctx context.Context,
	taskRecord taskpkg.Task,
	run taskpkg.Run,
	reason string,
)

}

func (r *taskRoleRuntime) activateRun(
	ctx context.Context,
	taskRecord taskpkg.Task,
	run taskpkg.Run,
	reason string,
) error {
	if ctx == nil {
		return errors.New("daemon: task role activation context is required")
	}
	activation, ok, err := r.activationForRun(ctx, taskRecord, run)
	if err != nil || !ok {
		return err
	}

	r.mu.Lock()
	defer r.mu.Unlock()

	existing, err := r.activeRoleSession(ctx, activation)
	if err != nil {
		return err
	}
	if existing != nil {
		r.logger.Info(
			"daemon: task role session already active",
			taskRoleRuntimeTaskIDKey, activation.TaskID,
			"run_id", activation.RunID,
			"agent_name", activation.AgentName,
			"channel", activation.Channel,
			"reason", reason,
		)
		return nil
	}

	info, err := r.startRoleSession(ctx, activation)
	if err != nil {
		return err
	}
	r.logger.Info(
		"daemon: task role session started",
		"session_id", info.ID,
		taskRoleRuntimeTaskIDKey, activation.TaskID,
		"run_id", activation.RunID,
		"agent_name", activation.AgentName,
		"channel", activation.Channel,
		"reason", reason,
	)
	return nil
}

func (r *taskRoleRuntime) activationForRun(
	ctx context.Context,