def save_episode(self):
        """
        Trigger the save operation. This sets the save flag, and the process_queue thread will handle it.
        """
        self.need_save = True  # Set the save flag
        print(f"==> Episode saved start...")

        Trigger the save operation. This sets the save flag, and the process_queue thread will handle it.
        
deploy/teleop/utils/episode_writer.py