diff --git a/kube/client/client.go b/kube/client/client.go index d9378bea4..3f1477c92 100644 --- a/kube/client/client.go +++ b/kube/client/client.go @@ -96,6 +96,7 @@ func (kc *KubeClient) GetLogs(ctx context.Context, projectName string, consumer for _, pod := range pods.Items { request := kc.client.CoreV1().Pods(kc.namespace).GetLogs(pod.Name, &corev1.PodLogOptions{Follow: follow}) service := pod.Labels[compose.ServiceTag] + w := utils.GetWriter(pod.Name, service, string(pod.UID), func(event compose.ContainerEvent) { consumer.Log(event.Name, event.Service, event.Source, event.Line) })