Skip to content
This repository has been archived by the owner on Apr 26, 2024. It is now read-only.

Commit

Permalink
Update prefect_kubernetes/utilities.py
Browse files Browse the repository at this point in the history
Co-authored-by: Alexander Streed <[email protected]>
  • Loading branch information
urimandujano and desertaxle authored Jan 19, 2024
1 parent 7c7e664 commit 71df5f1
Showing 1 changed file with 1 addition and 1 deletion.
2 changes: 1 addition & 1 deletion prefect_kubernetes/utilities.py
Original file line number Diff line number Diff line change
Expand Up @@ -301,7 +301,7 @@ def stream(self, func: Callable, *args, cache: Optional[Set] = None, **kwargs):
def api_object_stream(self, func: Callable, *args, **kwargs):
"""
Create a cache to maintain a record of API objects that have been
seen. This is useful because `_stream` will reconnect a stream on
seen. This is useful because `stream` will reconnect a stream on
`self.reconnect_exceptions` and on reconnect it will restart streaming all
objects. This cache prevents the same object from being yielded twice.
Expand Down

0 comments on commit 71df5f1

Please sign in to comment.