dbg

rh-pre-commit.version: 2.2.0
rh-pre-commit.check-secrets: ENABLED

pkg/watcher/reconciler/dynamic/dynamic.go

@@ -439,12 +439,18 @@ func (r *Reconciler) streamLogs(ctx context.Context, o results.Object, labelKey,
 		containers = append(containers, pod.Spec.Containers...)
 		for _, container := range containers {
 			pipelineName := pod.Labels[pipeline.PipelineLabelKey]
+			pipelineTaskName := pod.Labels[pipeline.PipelineTaskLabelKey]
 			taskName := pod.Labels[pipeline.TaskLabelKey]
 			logger.Infow("GGMGGM labels",
 				zap.String("pipeline", pipelineName),
+				zap.String("pipelineTask", pipelineTaskName),
 				zap.String("task", taskName))
 
-			ba, podLogsErr := r.getPodLogs(ctx, o.GetNamespace(), pod.Name, container.Name, labelKey, taskName)
+			task := taskName
+			if len(task) == 0 {
+				task = pipelineTaskName
+			}
+			ba, podLogsErr := r.getPodLogs(ctx, o.GetNamespace(), pod.Name, container.Name, labelKey, task)
 			if podLogsErr != nil {
 				return podLogsErr
 			}