def upload()

in roles/gcs-upload/library/gcs_upload.py [0:0]

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

    def upload(self, file_list):
        """Spin up thread pool to upload to storage"""
        num_threads = min(len(file_list), MAX_UPLOAD_THREADS)
        threads = []
        queue = queuelib.Queue()
        # add items to queue
        for f in file_list:
            queue.put(f)

        for x in range(num_threads):
            t = threading.Thread(target=self.post_thread, args=(queue,))
            threads.append(t)
            t.start()

        for t in threads:
            t.join()