fix(healthcheck): poll in healthcheck (#274)

fix poll is missing from the helthcheck
getsentry · Jul 19, 2023 · 836bfab · 836bfab
1 parent 256dc65
commit 836bfab
Showing 1 changed file with 1 addition and 0 deletions.
diff --git a/arroyo/processing/strategies/healthcheck.py b/arroyo/processing/strategies/healthcheck.py
@@ -25,6 +25,7 @@ def submit(self, message: Message[TStrategyPayload]) -> None:
         self.__next_step.submit(message)
 
     def poll(self) -> None:
+        self.__next_step.poll()
         now = time.time()
 
         if (