tvalentyn commented on code in PR #32136:
URL: https://github.com/apache/beam/pull/32136#discussion_r1715732129
##########
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 receive the exception and the element being processed in as args
What will be the exception when the processing has exceeded the configured
timeout?
--
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: github-unsubscr...@beam.apache.org
For queries about this service, please contact Infrastructure at:
us...@infra.apache.org
