@@ -389,18 +389,15 @@ def _update_log_interval(self) -> None:
389389 if last_address is None or last_slot is None :
390390 return
391391
392- last_timestamp = self ._logs [last_address ][last__slot ].timestamp
392+ last_timestamp = self ._logs [last_address ][last_slot ].timestamp
393393 address , slot = calc_log_address (last_address , last_slot , - 1 )
394- while self ._log_exists (address , slot ):
394+ if self ._log_exists (address , slot ):
395395 delta : timedelta = (
396396 last_timestamp - self ._logs [address ][slot ].timestamp
397397 )
398398 self ._log_interval = int (
399399 delta .total_seconds () / MINUTE_IN_SECONDS
400400 )
401- break
402-
403- address , slot = calc_log_address (address , slot , - 1 )
404401
405402 if (
406403 self ._log_interval is not None
@@ -442,7 +439,7 @@ def _reset_log_references(self) -> None:
442439 return
443440
444441 for address in self ._logs :
445- for slot , _ in self ._logs [address ].items ():
442+ for slot , log_record in self ._logs [address ].items ():
446443 if self ._last_log_timestamp is None :
447444 self ._last_log_timestamp = log_record .timestamp
448445 if self ._last_log_timestamp <= log_record .timestamp :
@@ -458,17 +455,13 @@ def _reset_log_references(self) -> None:
458455 self ._first_log_slot = slot
459456
460457 def _update_first_log_reference (
461- self , address : int , slot : int , timestamp : datetime , is_consumption : bool
458+ self , address : int , slot : int , timestamp : datetime
462459 ) -> None :
463460 """Update references to first (oldest) log record."""
464461 if self ._first_log_timestamp is None or self ._first_log_timestamp > timestamp :
465462 self ._first_log_address = address
466463 self ._first_log_slot = slot
467464 self ._first_log_timestamp = timestamp
468- elif self ._first_log_timestamp == timestamp and is_consumption :
469- self ._first_log_address = address
470- self ._first_log_slot = slot
471- self ._first_log_timestamp = timestamp
472465
473466 def _update_log_references (self , address : int , slot : int ) -> None :
474467 """Update next expected log timestamps."""
0 commit comments