From 6d105e57110d7d933334eb9c215b9d0261dc531f Mon Sep 17 00:00:00 2001 From: Shunping Huang Date: Sat, 21 Dec 2024 10:08:12 -0500 Subject: [PATCH] Minor changes on exception message. --- .../apache_beam/runners/dataflow/internal/apiclient.py | 5 +++-- 1 file changed, 3 insertions(+), 2 deletions(-) diff --git a/sdks/python/apache_beam/runners/dataflow/internal/apiclient.py b/sdks/python/apache_beam/runners/dataflow/internal/apiclient.py index f9b84e16906..530b2e8efd7 100644 --- 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):