def test_collect_valid_content_to_encode_invalid_content_type(self):
        """Ensure an internal error is raised when the content type is invalid."""
        preprocessed_content = [["invalid_string"]]
        with self.assertRaises(ValueError):
            self.pipeline._collect_valid_content_to_encode(preprocessed_content)
Ensure an internal error is raised when the content type is invalid.
tests/unit_tests/marqo/inference/native_inference/test_languagebind_model_inference_pipeline.py