def processJobResults()

in src/get-feedback.py [0:0]
21 lines of code
5 McCabe index (conditional complexity)

    def processJobResults(self, labelVerificationJobName):
        
        finalManifestItems = {}

        sageMakerClient = AwsHelper().getClient("sagemaker", self.inputParameters["awsRegion"])
        response = sageMakerClient.describe_labeling_job(LabelingJobName=labelVerificationJobName)

        outputManifestUri = response["LabelingJobOutput"]["OutputDatasetS3Uri"]

        jobOutputText = S3Helper.readFromS3Uri(outputManifestUri)

        outputManifestItems = jobOutputText.splitlines()

        for outputManifestItemText in outputManifestItems:
            eoutputManifestItem = json.loads(outputManifestItemText)

            imagesAndLabels = json.loads(S3Helper.readFromS3Uri(eoutputManifestItem["source-ref"]))
            
            i = 0
            for imageAndLabel in imagesAndLabels:
                if(eoutputManifestItem['labels']['item-{}'.format(i)] == "Yes"):
                    if(imageAndLabel["imageUrl"] in finalManifestItems):
                        finalManifestItem = finalManifestItems[imageAndLabel["imageUrl"]]
                    else:
                        finalManifestItem = []
                        finalManifestItems[imageAndLabel["imageUrl"]] = finalManifestItem
                        
                    finalManifestItem.append({"label": imageAndLabel["label"], "confidence": 1})
                    
                i += 1
        
        self.generateOutput(finalManifestItems, labelVerificationJobName)