[Cherrypick] Fix PostCommit Python job (#35709)

[Cherrypick] Fix PostCommit Python job (#35709)

Author: Amar3tto

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

@@ -67,8 +67,11 @@ def parse_known_args(argv):
 
 class PostProcessor(beam.DoFn):
   def process(self, element: PredictionResult) -> Iterable[str]:
-    yield "Input: " + str(element.example) + " Output: " + str(
-        element.inference[1][0].content.parts[0].text)
+    try:
+      output_text = element.inference[1][0].content.parts[0].text
+      yield f"Input: {element.example}, Output: {output_text}"
+    except Exception:
+      yield f"Can't decode inference for element: {element.example}"
 
 
 def run(

sdks/python/apache_beam/io/debezium.py

@@ -155,7 +155,7 @@ def __init__(
         username=username,
         password=password,
         host=host,
-        port=port,
+        port=str(port),
         max_number_of_records=max_number_of_records,
         connection_properties=connection_properties)
     self.expansion_service = expansion_service or default_io_expansion_service()