Polish .with_exception_handling docstring (apache#32739)

* replace 'record' with 'input' and fix example * more tweaking
reeba212 · Dec 4, 2024 · 1235bba · 1235bba
1 parent 7d8ec0a
commit 1235bba
Showing 1 changed file with 4 additions and 2 deletions.
diff --git a/sdks/python/apache_beam/transforms/core.py b/sdks/python/apache_beam/transforms/core.py
@@ -1593,8 +1593,10 @@ def with_exception_handling(
       threshold=1,
       threshold_windowing=None,
       timeout=None,
-      error_handler=None):
-    """Automatically provides a dead letter output for skipping bad records.
+      error_handler=None,
+      on_failure_callback: typing.Optional[typing.Callable[
+          [Exception, typing.Any], None]] = None):
+    """Automatically provides a dead letter output for saving bad inputs.
     This can allow a pipeline to continue successfully rather than fail or
     continuously throw errors on retry when bad elements are encountered.