From d4dd58b2c4c4b5867ace4bdd34e1bcc32de963cc Mon Sep 17 00:00:00 2001 From: Mohamed Awnallah <69568555+mohamedawnallah@users.noreply.github.com> Date: Sat, 5 Oct 2024 01:36:44 +0300 Subject: [PATCH] sdks/python/apache_beam/io: add note on `output_fn` ctor arg to indicate that It is unused and only retained for backward compatibility (#32635) In this commit, we add unused note on `output_fn` constructor argument in `WriteToFiles` class and only retained for backward compatibility. Signed-off-by: Mohamed Awnallah --- sdks/python/apache_beam/io/fileio.py | 2 ++ 1 file changed, 2 insertions(+) diff --git a/sdks/python/apache_beam/io/fileio.py b/sdks/python/apache_beam/io/fileio.py index 378ecf71920d..d9b2a2040675 100644 --- a/sdks/python/apache_beam/io/fileio.py +++ b/sdks/python/apache_beam/io/fileio.py @@ -557,6 +557,8 @@ def __init__( class signature or an instance of FileSink to this parameter. If none is provided, a ``TextSink`` is used. shards (int): The number of shards per destination and trigger firing. + output_fn (callable, optional): A callable to process the output. This + parameter is currently unused and retained for backward compatibility. max_writers_per_bundle (int): The number of writers that can be open concurrently in a single worker that's processing one bundle. """