Skip to content

Commit

Permalink
Refactor timestamp setting
Browse files Browse the repository at this point in the history
  • Loading branch information
ocelotl committed Oct 7, 2020
1 parent 1b3bfa3 commit 555d32b
Showing 1 changed file with 1 addition and 4 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -210,13 +210,10 @@ def take_checkpoint(self):

def merge(self, other):
last = self.checkpoint
self.last_update_timestamp = max(
self.last_update_timestamp, other.last_update_timestamp
)
super().merge(other)
if self.last_update_timestamp == other.last_update_timestamp:
last = other.checkpoint
self.checkpoint = last
super().merge(other)


class ValueObserverAggregator(Aggregator):
Expand Down

0 comments on commit 555d32b

Please sign in to comment.