func FlinkClusterTaskLogs()

in pkg/flink/handler.go [168:191]

• 20 lines of code
• 4 McCabe index (conditional complexity)

func FlinkClusterTaskLogs(ctx context.Context, config *Config, fi FlinkTaskLogsInput) ([]*core.TaskLog, error) {
	var taskLogs []*core.TaskLog

	p, err := logs.InitializeLogPlugins(&config.LogConfig)
	if err != nil {
		return nil, err
	}

	if p == nil {
		return taskLogs, nil
	}

	jobLog, err := p.GetTaskLogs(tasklog.Input{
		PodName:   fi.ClusterName,
		Namespace: fi.Namespace,
		LogName:   "(Job)",
	})
	if err != nil {
		return nil, err
	}
	taskLogs = append(taskLogs, jobLog.TaskLogs...)

	return taskLogs, nil
}