def __call__(self, results):
        """Perform the Decord initialization.

        Args:
            results (dict): The resulting dict to be modified and passed
                to the next transform in pipeline.
        """
        try:
            import decord
        except ImportError:
            raise ImportError(
                'Please run "pip install decord" to install Decord first.')
        if results['tar'] is False:
            if self.file_client is None:
                self.file_client = FileClient(self.io_backend, **self.kwargs)
            while True:
                try:
                    file_obj = io.BytesIO(self.file_client.get(results['filename']))
                except OSError as e:
                    print(f"Catched exception: {str(e)}. Re-trying...")
                    import time
                    time.sleep(1)
                else:
                    break
        else:
            if self.tarfile is None:
                data_root = os.path.dirname(results['filename']) + '.tar'
                self.tarfile = tarfile.open(data_root)
            video_name = results['filename'].split('/')[-1]
            iob = self.tarfile.extractfile(video_name)
            iob = iob.read()
            file_obj = io.BytesIO(iob)
        container = decord.VideoReader(file_obj, num_threads=self.num_threads)
        results['video_reader'] = container
        results['total_frames'] = len(container)
        return results
Perform the Decord initialization.

        Args:
            results (dict): The resulting dict to be modified and passed
                to the next transform in pipeline.
        
EVA-01/video/datasets/pipeline.py