in src/get-feedback.py [0:0]
def processJobResults(self, boundingBoxJobs):
automlManifestItems = {}
sageMakerClient = AwsHelper().getClient("sagemaker", self.inputParameters["awsRegion"])
for job in boundingBoxJobs:
response = sageMakerClient.describe_labeling_job(LabelingJobName=job)
outputManifestUri = response["LabelingJobOutput"]["OutputDatasetS3Uri"]
outputBucketName, outputFileName = S3Helper.parseBucketAndDocumentName(outputManifestUri)
jobOutputText = S3Helper.readFromS3(outputBucketName, outputFileName)
outputManifestItems = jobOutputText.splitlines()
for outputManifestItemText in outputManifestItems:
eoutputManifestItem = json.loads(outputManifestItemText)
if(eoutputManifestItem["source-ref"] in automlManifestItems):
automlManifestItem = automlManifestItems[eoutputManifestItem["source-ref"]]
oid = uuid.uuid1()
automlManifestItem["{}-bounding-box-new".format(oid)] = eoutputManifestItem["bounding-box-new"]
automlManifestItem["{}-bounding-box-new-metadata".format(oid)] = eoutputManifestItem["bounding-box-new-metadata"]
else:
automlManifestItem = { "source-ref" : eoutputManifestItem["source-ref"],
"bounding-box-new": eoutputManifestItem["bounding-box-new"],
"bounding-box-new-metadata": eoutputManifestItem["bounding-box-new-metadata"]
}
automlManifestItems[eoutputManifestItem["source-ref"]] = automlManifestItem
self.generateOutput(automlManifestItems)