Skip to content

Commit d4f5372

Browse files
authored
Improve error message for decoding input stream (#36823)
* Improve error message for decoding input stream * Fix string interpolation in error message
1 parent 3af78a7 commit d4f5372

File tree

1 file changed

+4
-2
lines changed

1 file changed

+4
-2
lines changed

sdks/python/apache_beam/runners/worker/bundle_processor.py

Lines changed: 4 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -234,9 +234,11 @@ def process_encoded(self, encoded_windowed_values: bytes) -> None:
234234
decoded_value = self.windowed_coder_impl.decode_from_stream(
235235
input_stream, True)
236236
except Exception as exn:
237+
coder = str(self.windowed_coder)
238+
step = self.name_context.step_name
237239
raise ValueError(
238-
"Error decoding input stream with coder " +
239-
str(self.windowed_coder)) from exn
240+
f"Error decoding input stream with coder {coder} in step {step}"
241+
) from exn
240242
self.output(decoded_value)
241243

242244
def monitoring_infos(

0 commit comments

Comments
 (0)