Ensure log group is created when multiple prefixes exist for the BatchAPI kind (#1468)

Author: RobertLucian

pkg/operator/resources/batchapi/logging.go

@@ -43,17 +43,16 @@ func operatorLogStream(jobKey spec.JobKey) string {
 
 // Checks if log group exists before creating it
 func ensureLogGroupForAPI(apiName string) error {
-	output, err := config.AWS.CloudWatchLogs().DescribeLogGroups(&cloudwatchlogs.DescribeLogGroupsInput{
-		Limit:              aws.Int64(1),
-		LogGroupNamePrefix: aws.String(logGroupNameForAPI(apiName)),
-	})
+	apiNameLogGroup := logGroupNameForAPI(apiName)
+
+	logGroupExists, err := config.AWS.DoesLogGroupExist(apiNameLogGroup)
 	if err != nil {
-		return errors.WithStack(err)
+		return err
 	}
 
-	if len(output.LogGroups) == 0 {
+	if !logGroupExists {
 		input := &cloudwatchlogs.CreateLogGroupInput{
-			LogGroupName: aws.String(logGroupNameForAPI(apiName)),
+			LogGroupName: aws.String(apiNameLogGroup),
 		}
 
 		// There should always be a default tag. Tags are only empty when running local operator without the tags field specified in a cluster.yaml.