AnandInguva commented on code in PR #25393:
URL: https://github.com/apache/beam/pull/25393#discussion_r1103204066
##########
sdks/python/apache_beam/ml/inference/utils.py:
##########
@@ -125,17 +125,21 @@ def __init__(
"""
Watches a directory for updates to files matching a given file pattern.
- **Note**: Start timestamp will be defaulted to timestamp when pipeline
- was run. All the files matching file_pattern, that are uploaded before
- the pipeline started will be discarded.
-
Args:
- file_pattern: A glob pattern used to watch a directory for model
- updates.
+ file_pattern: The file path to read from as a local file path or a
+ GCS ``gs://`` path. The path can contain glob characters
+ (``*``, ``?``, and ``[...]`` sets).
interval: Interval at which to check for files matching file_pattern
in seconds.
stop_timestamp: Timestamp after which no more files will be checked.
+ Constraints:
+ 1. If the file is read and then there is an update to that file, this
+ transform will ignore that update. Always update a file with unique
+ name.
Review Comment:
Changed the wording
--
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]
