···163163}
164164165165// SetupWorkflow creates a SpindleSet CR for the workflow.
166166-func (e *KubernetesEngine) SetupWorkflow(ctx context.Context, wid models.WorkflowId, wf *models.Workflow) error {
166166+func (e *KubernetesEngine) SetupWorkflow(ctx context.Context, wid models.WorkflowId, wf *models.Workflow, wfLogger models.WorkflowLogger) error {
167167 logger := log.FromContext(ctx).WithValues("workflow", wid.Name, "pipeline", wid.PipelineId.Rkey)
168168169169 // Extract pre-computed workflow data
···196196 // Retrieve secrets for this repository from the vault
197197 var repoSecrets []loomv1alpha1.SecretData
198198 if e.vault != nil && didSlashRepo != "" {
199199- unlockedSecrets, err := e.vault.GetSecretsUnlocked(ctx, secrets.DidSlashRepo(didSlashRepo))
199199+ unlockedSecrets, err := e.vault.GetSecretsUnlocked(ctx, secrets.RepoIdentifier(didSlashRepo))
200200 if err != nil {
201201 logger.Error(err, "Failed to retrieve secrets from vault", "repo", didSlashRepo)
202202 } else if len(unlockedSecrets) > 0 {
···352352// RunStep streams logs for the specific step and waits for that step to complete.
353353// For Kubernetes engine, all steps run in a single Job, but we stream logs incrementally
354354// as each step executes. Each RunStep call blocks until that step's "end" control event is received.
355355-func (e *KubernetesEngine) RunStep(ctx context.Context, wid models.WorkflowId, w *models.Workflow, idx int, secrets []secrets.UnlockedSecret, wfLogger *models.WorkflowLogger) error {
355355+func (e *KubernetesEngine) RunStep(ctx context.Context, wid models.WorkflowId, w *models.Workflow, idx int, secrets []secrets.UnlockedSecret, wfLogger models.WorkflowLogger) error {
356356 logger := log.FromContext(ctx).WithValues("workflow", wid.Name, "pipeline", wid.PipelineId.Rkey, "step", idx)
357357358358 // Query for the Job created by SpindleSetReconciler (only on first step)
···547547}
548548549549// readUntilStepEnd reads from the log stream until the end event for the specified step
550550-func (e *KubernetesEngine) readUntilStepEnd(ctx context.Context, stream *workflowLogStream, stepID int, workflow *models.Workflow, wfLogger *models.WorkflowLogger) error {
550550+func (e *KubernetesEngine) readUntilStepEnd(ctx context.Context, stream *workflowLogStream, stepID int, workflow *models.Workflow, wfLogger models.WorkflowLogger) error {
551551 scanner := stream.scanner
552552553553 for scanner.Scan() {