diff --git a/sdks/python/apache_beam/examples/snippets/transforms/elementwise/enrichment_test.py b/sdks/python/apache_beam/examples/snippets/transforms/elementwise/enrichment_test.py index 904b90710225..176eaa61e7a8 100644 --- a/sdks/python/apache_beam/examples/snippets/transforms/elementwise/enrichment_test.py +++ b/sdks/python/apache_beam/examples/snippets/transforms/elementwise/enrichment_test.py @@ -134,7 +134,8 @@ def test_enrichment_with_vertex_ai(self, mock_stdout): expected = sorted(validate_enrichment_with_vertex_ai()) for i in range(len(expected)): - self.assertEqual(set(output[i].split(',')), set(expected[i].split(','))) + self.assertEqual( + set(output[i][4:-1].split(',')), set(expected[i][4:-1].split(','))) def test_enrichment_with_vertex_ai_legacy(self, mock_stdout): enrichment_with_vertex_ai_legacy()