Skip to content

Commit 9fb6319

Browse files
committed
Add condition
1 parent 24df28a commit 9fb6319

File tree

1 file changed

+10
-4
lines changed

1 file changed

+10
-4
lines changed

sdks/python/apache_beam/examples/inference/gemini_text_classification.py

Lines changed: 10 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -70,13 +70,19 @@ def process(self, element: PredictionResult) -> Iterable[str]:
7070

7171
inference = getattr(element, "inference", None)
7272

73-
if hasattr(inference[1], "content"):
74-
yield inference[1].content.parts[0].text
73+
if not isinstance(inference, (tuple, list)) or len(inference) < 2:
74+
yield "Can't decode inference for element: " + str(element.example)
75+
return
76+
77+
prediction_payload = inference[1]
78+
79+
if hasattr(prediction_payload, "content"):
80+
yield prediction_payload.content.parts[0].text
7581
return
7682

77-
if isinstance(inference[1], (tuple, list)) and len(inference) > 1:
83+
if isinstance(prediction_payload, (tuple, list)) and prediction_payload:
7884
yield "Input: " + str(element.example) + " Output: " + str(
79-
inference[1][0].content.parts[0].text)
85+
prediction_payload[0].content.parts[0].text)
8086
else:
8187
yield "Can't decode inference for element: " + str(element.example)
8288

0 commit comments

Comments
 (0)