File tree Expand file tree Collapse file tree 1 file changed +4
-2
lines changed Expand file tree Collapse file tree 1 file changed +4
-2
lines changed Original file line number Diff line number Diff line change @@ -919,9 +919,10 @@ def earliest(self):
919919 earliest = []
920920 params = self ._params_from_filters ()
921921 start = params .get ("start" , MINIMUM_TIME )
922+ versions = self .versions ()
922923
923924 for s in self ._streams :
924- version = self . versions ()[ s .uuid ]
925+ version = versions . get ( s .uuid , 0 )
925926 point , _ = s .nearest (start , version = version , backward = False )
926927 earliest .append (point )
927928
@@ -944,9 +945,10 @@ def latest(self):
944945 latest = []
945946 params = self ._params_from_filters ()
946947 start = params .get ("end" , MAXIMUM_TIME )
948+ versions = self .versions ()
947949
948950 for s in self ._streams :
949- version = self . versions ()[ s .uuid ]
951+ version = versions . get ( s .uuid , 0 )
950952 point , _ = s .nearest (start , version = version , backward = True )
951953 latest .append (point )
952954
You can’t perform that action at this time.
0 commit comments