def test_run_pipeline(self, mock_format_results, mock_encode, mock_preprocess):
        """Test to ensure that the pipeline runs correctly."""
        mock_preprocess.return_value = [[("chunk", Mock(spec=Tensor))]]
        mock_encode.return_value = [np.random.rand(768)]
        mock_format_results.return_value = InferenceResult(result=[[]])

        result = self.pipeline.run_pipeline()

        mock_preprocess.assert_called_once()
        mock_encode.assert_called_once()
        mock_format_results.assert_called_once()
        self.assertIsInstance(result, InferenceResult)
Test to ensure that the pipeline runs correctly.
tests/unit_tests/marqo/inference/native_inference/test_languagebind_model_inference_pipeline.py