Minor changes on exception message.

apache · Dec 21, 2024 · 6d105e5 · 6d105e5
1 parent da834fd
commit 6d105e5
Showing 1 changed file with 3 additions and 2 deletions.
diff --git a/sdks/python/apache_beam/runners/dataflow/internal/apiclient.py b/sdks/python/apache_beam/runners/dataflow/internal/apiclient.py
@@ -717,8 +717,9 @@ def stage_file_with_retry(
           raise exn
         else:
           raise retry.PermanentException(
-              "Failed to tell or seek in stream because we caught exception:",
-              ''.join(traceback.format_exception_only(exn.__class__, exn)))
+              "Skip retrying because we caught exception:",
+              ''.join(traceback.format_exception_only(exn.__class__, exn)),
+              ', but the stream is not seekable')
 
   @retry.no_retries  # Using no_retries marks this as an integration point.
   def create_job(self, job):