From ff2ea3c3f0a9e5ee4c39d5a512d6bd78f4a7f0aa Mon Sep 17 00:00:00 2001 From: urimandujano Date: Fri, 19 Jan 2024 15:59:12 -0600 Subject: [PATCH] Update prefect_kubernetes/utilities.py Co-authored-by: Alexander Streed --- prefect_kubernetes/utilities.py | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/prefect_kubernetes/utilities.py b/prefect_kubernetes/utilities.py index 7a2359b..d5c0381 100644 --- a/prefect_kubernetes/utilities.py +++ b/prefect_kubernetes/utilities.py @@ -247,9 +247,9 @@ def stream(self, func: Callable, *args, cache: Optional[Set] = None, **kwargs): configurable exceptions and deduplicate results on reconnects if streaming API objects and a cache is provided. - Note that client functions that produce a stream of logs will + Note that client functions that produce a stream will restart a stream from the beginning of the log's history on reconnect. - It is possible for duplicate logs to be yielded. + If a cache is not provided, it is possible for duplicate entries to be yielded. Args: func: A Kubernetes client function to call which produces a stream