damccorm commented on code in PR #32136:
URL: https://github.com/apache/beam/pull/32136#discussion_r1716502457
##########
sdks/python/apache_beam/transforms/core.py:
##########
@@ -1620,6 +1622,11 @@ def with_exception_handling(
defaults to the windowing of the input.
timeout: If the element has not finished processing in timeout seconds,
raise a TimeoutError. Defaults to None, meaning no time limit.
+ on_failure_callback: If an element fails or times out,
+ on_failure_callback will be invoked. It will receive the exception
+ and the element being processed in as args. Be careful with this
Review Comment:
It will be a `TimeoutError`, updated the docstring - thanks
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
