fixup! generator: watch: use max startTime from events

awslogs/core.py

@@ -121,12 +121,9 @@ def generator():
 
             while True:
                 response = self.client.filter_log_events(**kwargs)
+                events = response.get('events', [])
 
-                for event in response.get('events', []):
-                    if (self.watch and
-                            event['timestamp'] > kwargs.get('startTime', 0)):
-                        kwargs['startTime'] = event['timestamp']
-
+                for event in events:
                     if event['eventId'] not in interleaving_sanity:
                         interleaving_sanity.append(event['eventId'])
                         yield event
@@ -139,6 +136,13 @@ def generator():
                     time.sleep(1)
                     if 'nextToken' in kwargs:
                         del kwargs['nextToken']
+
+                    if events:
+                        kwargs['startTime'] = max(
+                            event['timestamp'] for event in events
+                        )
+                        assert kwargs['startTime'] == events[-1]['timestamp']
+
                 else:
                     raise StopIteration