Skip to content

Commit

Permalink
fix: Make arroyo.consumer.latency a timing metric (#316)
Browse files Browse the repository at this point in the history
  • Loading branch information
lynnagara committed Dec 21, 2023
1 parent af4be59 commit 97cfba8
Showing 1 changed file with 1 addition and 1 deletion.
2 changes: 1 addition & 1 deletion arroyo/processing/strategies/commit.py
Original file line number Diff line number Diff line change
Expand Up @@ -27,7 +27,7 @@ def submit(self, message: Message[Any]) -> None:
now = time.time()
if self.__last_record_time is None or now - self.__last_record_time > 1:
if message.timestamp is not None:
self.__metrics.increment(
self.__metrics.timing(
"arroyo.consumer.latency", now - message.timestamp.timestamp()
)
self.__last_record_time = now
Expand Down

0 comments on commit 97cfba8

Please sign in to comment.