From 2bba3871d2363ed30e9159c81f19f4e63f0017ae Mon Sep 17 00:00:00 2001 From: urimandujano Date: Fri, 19 Jan 2024 12:29:29 -0600 Subject: [PATCH] Update prefect_kubernetes/utilities.py Co-authored-by: Alexander Streed --- prefect_kubernetes/utilities.py | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/prefect_kubernetes/utilities.py b/prefect_kubernetes/utilities.py index 048b7a6..463f83f 100644 --- a/prefect_kubernetes/utilities.py +++ b/prefect_kubernetes/utilities.py @@ -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