From 827e7e55605931ed29d652c3d59a45bc951c0ea1 Mon Sep 17 00:00:00 2001 From: Ethan Tang Date: Sat, 2 Nov 2024 15:31:24 -0700 Subject: [PATCH] doc change --- streaming/base/util.py | 1 + 1 file changed, 1 insertion(+) diff --git a/streaming/base/util.py b/streaming/base/util.py index e4c4095ad..ea6a3d3d6 100644 --- a/streaming/base/util.py +++ b/streaming/base/util.py @@ -491,6 +491,7 @@ def retry( # type: ignore def clean_up(): # Do clean up stuff here + print("cleaning up") @retry(RuntimeError, clean_up_fn=clean_up, num_attempts=3, initial_backoff=0.1) def flaky_function():