Method encode_task

datastudio/models/base.py:468–470

(item)

        encoded_cache = {}

        def encode_task(item):
            img_id, img = item
            return img_id, self.encode_image_directly(img)

        try:
            with concurrent.futures.ThreadPoolExecutor(max_workers=16) as executor: