error handling (#6684)

iamayushm · web-flow · commit 555b987daf6a · 2025-06-20T21:16:45.000+05:30
diff --git a/pkg/k8s/application/k8sApplicationService.go b/pkg/k8s/application/k8sApplicationService.go
@@ -434,6 +434,7 @@ func (impl *K8sApplicationServiceImpl) GetPodLogs(ctx context.Context, request *
 	restConfig, err := impl.k8sCommonService.GetRestConfigOfCluster(ctx, request)
 	if err != nil {
 		impl.logger.Errorw("error in getting rest config by clusterId", "err", err, "clusterId", clusterId, "")
+		return nil, err
 	}
 	resp, err := impl.K8sUtil.GetPodLogs(ctx, restConfig, resourceIdentifier.Name, resourceIdentifier.Namespace, podLogsRequest.SinceTime, podLogsRequest.TailLines, podLogsRequest.SinceSeconds, podLogsRequest.Follow, podLogsRequest.ContainerName, podLogsRequest.IsPrevContainerLogsEnabled)
 	if err != nil {

Original file line number	Diff line number	Diff line change
`@@ -434,6 +434,7 @@ func (impl K8sApplicationServiceImpl) GetPodLogs(ctx context.Context, request `
`434`	`434`	`restConfig, err := impl.k8sCommonService.GetRestConfigOfCluster(ctx, request)`
`435`	`435`	`if err != nil {`
`436`	`436`	`impl.logger.Errorw("error in getting rest config by clusterId", "err", err, "clusterId", clusterId, "")`
	`437`	`+ return nil, err`
`437`	`438`	`}`
`438`	`439`	`resp, err := impl.K8sUtil.GetPodLogs(ctx, restConfig, resourceIdentifier.Name, resourceIdentifier.Namespace, podLogsRequest.SinceTime, podLogsRequest.TailLines, podLogsRequest.SinceSeconds, podLogsRequest.Follow, podLogsRequest.ContainerName, podLogsRequest.IsPrevContainerLogsEnabled)`
`439`	`440`	`if err != nil {`