reset time

getsentry · Apr 10, 2024 · 27e38bf · 27e38bf
1 parent 0ae83ad
commit 27e38bf
Showing 1 changed file with 1 addition and 0 deletions.
diff --git a/arroyo/processing/strategies/run_task_with_multiprocessing.py b/arroyo/processing/strategies/run_task_with_multiprocessing.py
@@ -615,6 +615,7 @@ def __submit_batch(self, input_block_too_small: bool) -> None:
             self.__last_batch_time = time.time()
         else:
             self.__metrics.timing("arroyo.strategies.run_task_with_multiprocessing.batch.build_and_submit_time", time.time() - self.__last_batch_time)
+            self.__last_batch_time = time.time()
 
     def __forward_invalid_offsets(self) -> None:
         if len(self.__invalid_messages):