revert changes

faust-streaming · Apr 1, 2024 · 32e7a51 · 32e7a51
1 parent d58a171
commit 32e7a51
Showing 1 changed file with 3 additions and 3 deletions.
diff --git a/faust/transport/drivers/aiokafka.py b/faust/transport/drivers/aiokafka.py
@@ -840,14 +840,14 @@ def _verify_aiokafka_event_path(self, now: float, tp: TP) -> bool:
         poll_at = None
         aiotp_state = assignment.state_value(aiotp)
         if aiotp_state and aiotp_state.timestamp:
-            poll_at = aiotp_state.timestamp / 1000
+            poll_at = aiotp_state.timestamp
         if poll_at is None:
             if secs_since_started >= self.tp_fetch_request_timeout_secs:
                 # NO FETCH REQUEST SENT AT ALL SINCE WORKER START
                 self.log.error(
                     SLOW_PROCESSING_NO_FETCH_SINCE_START,
                     tp,
-                    secs_since_started,
+                    humanize_seconds_ago(secs_since_started),
                 )
             return True
 
@@ -857,7 +857,7 @@ def _verify_aiokafka_event_path(self, now: float, tp: TP) -> bool:
             self.log.error(
                 SLOW_PROCESSING_NO_RECENT_FETCH,
                 tp,
-                secs_since_request,
+                humanize_seconds_ago(secs_since_request),
             )
             return True