def load_results()

in components/dpu-workflow/src/utils/gcs_utils.py [0:0]

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

    def load_results(self):
        blobs = BucketRegistry.get_bucket(self.bucket_name).list_blobs(
            prefix=f"{self.processing_prefix}/{self.result_folder_prefix}",
            match_glob="**/*.json",
        )
        results = {}

        for blob in blobs:
            if not FormClassifierResult.is_json(blob):
                continue

            input_blob_name = self.derive_input_blob_name(blob.name)
            if input_blob_name not in results:
                results[input_blob_name] = []

            results[input_blob_name].extend(self.extract_classifier_result(blob))

        self.results = results