add additional sorting to stabilize remove stale segments

GlobalFishingWatch · Jul 14, 2022 · 85231e7 · 85231e7
1 parent d90b3d3
commit 85231e7
Showing 1 changed file with 3 additions and 1 deletion.
diff --git a/gpsdio_segment/segmenter.py b/gpsdio_segment/segmenter.py
@@ -197,7 +197,9 @@ def _remove_excess_segments(self):
         while len(self._segments) >= self.max_open_segments:
             # Remove oldest segment
             segs = list(self._segments.items())
-            segs.sort(key=lambda x: x[1].last_msg["timestamp"])
+            segs.sort(
+                key=lambda x: (x[1].last_msg["timestamp"], x[1].last_msg["msgid"])
+            )
             stalest_seg_id, _ = segs[0]
             log("Removing stale segment {}".format(stalest_seg_id))
             yield from self._clean_segment(