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 3e41181 commit 2bba387
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 @@ -223,7 +223,7 @@ def __init__(
)
self.reconnect_exceptions = tuple(reconnect_exceptions)

def _stream(self, cache: Optional[FIFOCache], func: Callable, *args, **kwargs):
def _stream(self, func: Callable, *args, cache: Optional[FIFOCache] = None, **kwargs):
"""
A private method for streaming API objects or logs from a Kubernetes
client function. This method will reconnect the stream on certain
Expand Down

0 comments on commit 2bba387

Please sign in to comment.